[
https://issues.apache.org/jira/browse/STORM-374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jungtaek Lim updated STORM-374:
-------------------------------
Fix Version/s: (was: 0.9.1-incubating)
> storm0.9.1&kafka0.8.1 with storm-kafka-0.8-plus-0.5.0 can not run
> -----------------------------------------------------------------
>
> Key: STORM-374
> URL: https://issues.apache.org/jira/browse/STORM-374
> Project: Apache Storm
> Issue Type: Bug
> Components: storm-kafka
> Affects Versions: 0.9.1-incubating
> Environment: centos5.4
> java1.6.0_45
> Reporter: cha369
>
> 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$eval5100$fn__5101$fn__5116$fn__5145.invoke(executor.clj:562)
> ~[na:na]
> at backtype.storm.util$async_loop$fn__390.invoke(util.clj:433)
> ~[na:na]
> at clojure.lang.AFn.run(AFn.java:24) [clojure-1.4.0.jar:na]
> at java.lang.Thread.run(Thread.java:662) [na:1.6.0_45]
> 12949 [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$eval5100$fn__5101$fn__5116$fn__5145.invoke(executor.clj:562)
> ~[na:na]
> at backtype.storm.util$async_loop$fn__390.invoke(util.clj:433)
> ~[na:na]
> at clojure.lang.AFn.run(AFn.java:24) [clojure-1.4.0.jar:na]
> at java.lang.Thread.run(Thread.java:662) [na:1.6.0_45]
> 12971 [Thread-27-words] INFO backtype.storm.util - Halting process: ("Worker
> died")
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
