Yeah... this is one of the biggest problem of about kafka <-> storm integration (second is the kafka-storm module scala dependency version, but I explain this in another topic), and this is why I plan move to Spark... ok it's only near real time, but more stable than Storm (and native can run on hadoop yarn)
János Háber Fine Solution Ltd On Wed, Jun 11, 2014 at 9:59 PM, Derek Dagit <[email protected]> wrote: > Looks like a curator version mismatch... > > -- > Derek > > > On 6/11/14, 14:52, Anis Nasir wrote: > >> Dear all, >> >> >> I am getting below mentioned exception while running storm-kafka. Does >> anyone have seen this one before? >> >> >> 7800 [Thread-27-words] ERROR backtype.storm.util - Async loop died! >> java.lang.NoSuchMethodError: com.netflix.curator.framework. >> api.CreateBuilder.creatingParentsIfNeeded()Lcom/ >> netflix/curator/framework/api/ProtectACLCreateModePathAndBytesable; >> at storm.kafka.ZkState.writeBytes(ZkState.java:59) >> ~[storm-kafka-0.8-plus-0.5.0-SNAPSHOT.jar:na] >> at storm.kafka.ZkState.writeJSON(ZkState.java:53) >> ~[storm-kafka-0.8-plus-0.5.0-SNAPSHOT.jar:na] >> at storm.kafka.PartitionManager.commit(PartitionManager.java:188) >> ~[storm-kafka-0.8-plus-0.5.0-SNAPSHOT.jar:na] >> at storm.kafka.KafkaSpout.commit(KafkaSpout.java:169) >> ~[storm-kafka-0.8-plus-0.5.0-SNAPSHOT.jar:na] >> at storm.kafka.KafkaSpout.nextTuple(KafkaSpout.java:134) >> ~[storm-kafka-0.8-plus-0.5.0-SNAPSHOT.jar:na] >> at backtype.storm.daemon.executor$fn__3430$fn__3445$fn_ >> _3474.invoke(executor.clj:547) >> ~[storm-core-0.9.0.1.jar:na] >> at backtype.storm.util$async_loop$fn__444.invoke(util.clj:403) >> ~[storm-core-0.9.0.1.jar:na] >> at clojure.lang.AFn.run(AFn.java:24) ~[clojure-1.4.0.jar:na] >> at java.lang.Thread.run(Thread.java:701) ~[na:1.6.0_30] >> 7800 [Thread-27-words] ERROR backtype.storm.daemon.executor - >> java.lang.NoSuchMethodError: com.netflix.curator.framework. >> api.CreateBuilder.creatingParentsIfNeeded()Lcom/ >> netflix/curator/framework/api/ProtectACLCreateModePathAndBytesable; >> at storm.kafka.ZkState.writeBytes(ZkState.java:59) >> ~[storm-kafka-0.8-plus-0.5.0-SNAPSHOT.jar:na] >> at storm.kafka.ZkState.writeJSON(ZkState.java:53) >> ~[storm-kafka-0.8-plus-0.5.0-SNAPSHOT.jar:na] >> at storm.kafka.PartitionManager.commit(PartitionManager.java:188) >> ~[storm-kafka-0.8-plus-0.5.0-SNAPSHOT.jar:na] >> at storm.kafka.KafkaSpout.commit(KafkaSpout.java:169) >> ~[storm-kafka-0.8-plus-0.5.0-SNAPSHOT.jar:na] >> at storm.kafka.KafkaSpout.nextTuple(KafkaSpout.java:134) >> ~[storm-kafka-0.8-plus-0.5.0-SNAPSHOT.jar:na] >> at backtype.storm.daemon.executor$fn__3430$fn__3445$fn_ >> _3474.invoke(executor.clj:547) >> ~[storm-core-0.9.0.1.jar:na] >> at backtype.storm.util$async_loop$fn__444.invoke(util.clj:403) >> ~[storm-core-0.9.0.1.jar:na] >> at clojure.lang.AFn.run(AFn.java:24) ~[clojure-1.4.0.jar:na] >> at java.lang.Thread.run(Thread.java:701) ~[na:1.6.0_30] >> >> Regards >> Anis >> >>
