All,
We changed or paths in zookeeper and we are now seeing
java.lang.RuntimeException: java.lang.RuntimeException:
org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode
for /brokers/topics/warehouse_prices/partitions
at
storm.kafka.DynamicBrokersReader.getBrokerInfo(DynamicBrokersReader.java:81)
~[storm-kafka-0.9.4.jar:0.9.4]
at storm.kafka.trident.ZkBrokerReader.<init>(ZkBrokerReader.java:42)
~[storm-kafka-0.9.4.jar:0.9.4]
at storm.kafka.KafkaUtils.makeBrokerReader(KafkaUtils.java:57)
~[storm-kafka-0.9.4.jar:0.9.4]
at storm.kafka.KafkaSpout.open(KafkaSpout.java:87)
~[storm-kafka-0.9.4.jar:0.9.4]
at
backtype.storm.daemon.executor$fn__3371$fn__3386.invoke(executor.clj:522)
~[storm-core-0.9.4.jar:0.9.4]
at backtype.storm.util$async_loop$fn__460.invoke(util.clj:461)
~[storm-core-0.9.4.jar:0.9.4]
at clojure.lang.AFn.run(AFn.java:24) [clojure-1.5.1.jar:na]
at java.lang.Thread.run(Thread.java:744) [na:1.7.0_51]
Should this not be discovered by the Spout on startup?
