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