p.s. I launched some mvn target from storm-dist/binary directory to build binary distribution :)
On 11 June 2014 21:34, Haralds Ulmanis <[email protected]> wrote: > I got something similar, do not remember what exactly i did as it was > quite a simple. > check curator libs you are compiling in your code and libs which is storm > installation libs. Probably kafka lib you downloaded was used with > different version of curator. > Actually I've checked out storm incubation project and build everything > by myself, with slightly modified dependencies. I can be wrong, but If I > remember right, I launched some mvn target from storm-dist/binary directory. > > > > > On 11 June 2014 21:18, János Háber <[email protected]> wrote: > >> 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 >>>> >>>> >> >
