Hi, Does anybody know how to run topology in local mode with external Zookeeper
in Storm 0.9.2-incubating? I tried to configure the port and server but it
continues to throw out NullPointerException. Anyone can help? Thank you very
much!!
here is the code
public static void main(String[] args) throws Exception {
List<String> zkServers=new ArrayList<String>();
zkServers.add("127.0.0.1");
Config conf = new Config();
conf.setDebug(false);
conf.put(Config.STORM_ZOOKEEPER_SERVERS,zkServers);
conf.put(Config.STORM_ZOOKEEPER_PORT,2181);
// deploy on a local cluster
conf.setMaxTaskParallelism(3);
final LocalCluster cluster = new LocalCluster(conf);
final BuildMyTopology topology = new BuildMyTopology(cluster, conf,
"default");
topology.buildTopology();
topology.submit();
Thread.sleep(1000000);
LOG.info("Stopping topology.....................................!!");
cluster.killTopology("default");
cluster.shutdown();
}
the error
3476 [main] ERROR org.apache.zookeeper.server.NIOServerCnxnFactory - Thread
Thread[main,5,main] died
java.lang.NullPointerException: null
at clojure.lang.Reflector.invokeInstanceMethod(Reflector.java:26)
~[clojure-1.5.1.jar:na]
at backtype.storm.testing$submit_local_topology.invoke(testing.clj:253)
~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
at backtype.storm.LocalCluster$_submitTopology.invoke(LocalCluster.clj:38)
~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
at backtype.storm.LocalCluster.submitTopology(Unknown Source)
~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
at org.SimpleTopology.BuildMyTopology.submit(BuildMyTopology.java:68)
~[classes/:na]
at org.SimpleTopology.run.main(run.java:51) ~[classes/:na]
2015-06-18