You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@storm.apache.org by "cha369 (JIRA)" <ji...@apache.org> on 2014/06/27 11:25:24 UTC
[jira] [Created] (STORM-374) storm0.9.1&kafka0.8.1 with
storm-kafka-0.8-plus-0.5.0 can not run
cha369 created STORM-374:
----------------------------
Summary: 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 (Incubating)
Issue Type: Bug
Affects Versions: 0.9.1-incubating
Environment: centos5.4
java1.6.0_45
Reporter: cha369
Fix For: 0.9.1-incubating
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.2#6252)