I am still stuck on this issue. Can someone please help in upgrading the storm cluster 0.9.0.1 to use curator-framework 1.3.3 and zookeeper 3.4.5
Regards Anis On Wed, Jun 11, 2014 at 11:38 PM, Anis Nasir <[email protected]> wrote: > Regarding, 0.9.2-incubating-SNAPSHOT, it comes with the interface > ILocalCluster. I can not find any example using it. > > Regards > Anis > > > On Wed, Jun 11, 2014 at 11:14 PM, Anis Nasir <[email protected]> wrote: > >> Dear Jonas, >> >> I am getting the same exception running this build >> >> https://github.com/wurstmeister/storm-kafka-0.8-plus-test >> >> >> >> Regards >> Anis >> >> >> On Wed, Jun 11, 2014 at 11:07 PM, János Háber < >> [email protected]> wrote: >> >>> Anis: no, you using snapshot version of storm-kafka plugin plus the old >>> storm kafka plugin with storm 0.9.1... >>> I think storm-kafka 0.9.2-incubating-SNAPSHOT only compatible with >>> storm-core 0.9.2-incubating-SNAPSHOT >>> >>> In the 0.9.2-incubating-SNAPSHOT old curator framework (1.0.1) will be >>> changed to more recent version... >>> >>> as you see you using two version of storm-kafka. Remove the old one (the >>> 0.4.0 version) and increase the storm-core version >>> to 0.9.2-incubating-SNAPSHOT... >>> >>> maybe it's help... >>> >>> b0c1 >>> >>> János Háber >>> Fine Solution Ltd >>> >>> >>> >>> On Wed, Jun 11, 2014 at 11:03 PM, Anis Nasir <[email protected]> >>> wrote: >>> >>>> Dear Michael, >>>> >>>> I am using storm0.9.0.1 with kafka 0.8.1.1 and below mentioned are the >>>> dependencies. I tried with both storm-kafka 0.9.2-incubating-SNAPSHOT >>>> and storm-kafka-0.8-plus 0.4.0. The zookeeper version is 3.3.6. >>>> >>>> <dependency> >>>> <groupId>org.apache.storm</groupId> >>>> <artifactId>storm-core</artifactId> >>>> <version>0.9.1-incubating</version> >>>> </dependency> >>>> >>>> <dependency> >>>> <groupId>org.apache.storm</groupId> >>>> <artifactId>storm-kafka</artifactId> >>>> <version>0.9.2-incubating-SNAPSHOT</version> >>>> </dependency> >>>> >>>> <dependency> >>>> <groupId>net.wurstmeister.storm</groupId> >>>> <artifactId>storm-kafka-0.8-plus</artifactId> >>>> <version>0.4.0</version> >>>> </dependency> >>>> >>>> Regards >>>> Anis >>>> >>>> >>>> >>>> On Wed, Jun 11, 2014 at 10:51 PM, Michael G. Noll < >>>> [email protected]> wrote: >>>> >>>>> Can you share your build depencies, notably the versions of Storm and >>>>> storm-kafka and their respective artifactId and groupId? That is, the >>>>> snippets relevant to storm-core and storm-kafka from your pom.xml, >>>>> build.gradle, build.sbt, or similar build configuration file. Also, >>>>> please add from which Maven repositories you are downloading storm-core >>>>> and storm-kafka, respectively. >>>>> >>>>> Best, >>>>> Michael >>>>> >>>>> >>>>> >>>>> On 06/11/2014 09:52 PM, 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 >>>>> >>>>> >>>> >>> >> >
