These appear to classes generated from clojure. Are you building against the same version of storm that you are using to run the application?
On Mon, Mar 10, 2014 at 8:07 AM, James Hardy <[email protected]> wrote: > Hi > > I'm hoping someone can help. I've been learning Storm for the past few > hours and everything has been great however I'm getting > a java.lang.ClassNotFoundException: > backtype.storm.daemon.nimbus$normalize_conf$get_merged_conf_val__3916$fn__3917 > exception when trying to submit my topology to a local cluster. > > I have a simple spout which emits the string "go" and the ExclamationBolt > taken from the examples. I wanted to create a pipeline of bolts and so > created a topology: > > TopologyBuilder builder = new TopologyBuilder(); > builder.setSpout("test", new Spout()); > builder.setBolt("ex1", new ExclamationBolt()).shuffleGrouping("test"); > builder.setBolt("ex2", new ExclamationBolt()).shuffleGrouping("ex1"); > > This works fine no problem at all however when I add another bolt I get > the "Topology submission exception": > > TopologyBuilder builder = new TopologyBuilder(); > builder.setSpout("test", new Spout()); > builder.setBolt("ex1", new ExclamationBolt()).shuffleGrouping("test"); > builder.setBolt("ex2", new ExclamationBolt()).shuffleGrouping("ex1"); > builder.setBolt("ex3", new ExclamationBolt()).shuffleGrouping("ex2"); > > If anyone has any ideas they would be really appreciated. I feel like > I've hit a brick wall :/ > > Thanks > > James >
