Hi
I am trying to deploy a simple topology, which receives data from Kafka and should write it to Redis. But unfortunately I receive the following error message:
13659 [Thread-9] INFO o.a.s.d.worker - Worker 741ffc04-f217-41e7-b942-490c1895e7d7 for storm Topology-1-1464208228 on 66fa5b8f-87ee-42ee-8436-4fed29a20580:1024 has finished loading
13660 [Thread-9] INFO o.a.s.config - SET worker-user 741ffc04-f217-41e7-b942-490c1895e7d7
14512 [Thread-21-__system-executor[-1 -1]] INFO o.a.s.d.executor - Preparing bolt __system:(-1)
14536 [Thread-21-__system-executor[-1 -1]] INFO o.a.s.d.executor - Prepared bolt __system:(-1)
14553 [Thread-15-StoreToRedisBolt-executor[2 2]] INFO o.a.s.d.executor - Preparing bolt StoreToRedisBolt:(2)
14588 [Thread-19-KafkaSpout-executor[1 1]] INFO o.a.s.d.executor - Opening spout KafkaSpout:(1)
14597 [Thread-17-__acker-executor[3 3]] INFO o.a.s.d.executor - Preparing bolt __acker:(3)
14608 [Thread-17-__acker-executor[3 3]] INFO o.a.s.d.executor - Prepared bolt __acker:(3)
14635 [Thread-15-StoreToRedisBolt-executor[2 2]] INFO o.a.s.d.executor - Prepared bolt StoreToRedisBolt:(2)
14709 [Thread-19-KafkaSpout-executor[1 1]] ERROR o.a.s.util - Async loop died!
java.lang.NoSuchMethodError: com.google.common.cache.CacheBuilder.build()Lcom/google/common/cache/Cache;
at org.apache.curator.framework.imps.NamespaceWatcherMap.<init>(NamespaceWatcherMap.java:33) ~[realtime-v1-0.0.1-SNAPSHOT-jar-with-dependencies.jar:?]
at org.apache.curator.framework.imps.CuratorFrameworkImpl.<init>(CuratorFrameworkImpl.java:81) ~[realtime-v1-0.0.1-SNAPSHOT-jar-with-dependencies.jar:?]
at org.apache.curator.framework.CuratorFrameworkFactory$Builder.build(CuratorFrameworkFactory.java:145) ~[realtime-v1-0.0.1-SNAPSHOT-jar-with-dependencies.jar:?]
at org.apache.curator.framework.CuratorFrameworkFactory.newClient(CuratorFrameworkFactory.java:100) ~[realtime-v1-0.0.1-SNAPSHOT-jar-with-dependencies.jar:?]
at org.apache.storm.kafka.ZkState.newCurator(ZkState.java:45) ~[realtime-v1-0.0.1-SNAPSHOT-jar-with-dependencies.jar:?]
at org.apache.storm.kafka.ZkState.<init>(ZkState.java:61) ~[realtime-v1-0.0.1-SNAPSHOT-jar-with-dependencies.jar:?]
at org.apache.storm.kafka.KafkaSpout.open(KafkaSpout.java:75) ~[realtime-v1-0.0.1-SNAPSHOT-jar-with-dependencies.jar:?]
at org.apache.storm.daemon.executor$fn__8158$fn__8173.invoke(executor.clj:602) ~[storm-core-1.0.0.jar:1.0.0]
at org.apache.storm.util$async_loop$fn__554.invoke(util.clj:482) [storm-core-1.0.0.jar:1.0.0]
at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
at java.lang.Thread.run(Thread.java:745) [?:1.8.0_91]
14712 [Thread-19-KafkaSpout-executor[1 1]] ERROR o.a.s.d.executor -
java.lang.NoSuchMethodError: com.google.common.cache.CacheBuilder.build()Lcom/google/common/cache/Cache;
at org.apache.curator.framework.imps.NamespaceWatcherMap.<init>(NamespaceWatcherMap.java:33) ~[realtime-v1-0.0.1-SNAPSHOT-jar-with-dependencies.jar:?]
at org.apache.curator.framework.imps.CuratorFrameworkImpl.<init>(CuratorFrameworkImpl.java:81) ~[realtime-v1-0.0.1-SNAPSHOT-jar-with-dependencies.jar:?]
at org.apache.curator.framework.CuratorFrameworkFactory$Builder.build(CuratorFrameworkFactory.java:145) ~[realtime-v1-0.0.1-SNAPSHOT-jar-with-dependencies.jar:?]
at org.apache.curator.framework.CuratorFrameworkFactory.newClient(CuratorFrameworkFactory.java:100) ~[realtime-v1-0.0.1-SNAPSHOT-jar-with-dependencies.jar:?]
at org.apache.storm.kafka.ZkState.newCurator(ZkState.java:45) ~[realtime-v1-0.0.1-SNAPSHOT-jar-with-dependencies.jar:?]
at org.apache.storm.kafka.ZkState.<init>(ZkState.java:61) ~[realtime-v1-0.0.1-SNAPSHOT-jar-with-dependencies.jar:?]
at org.apache.storm.kafka.KafkaSpout.open(KafkaSpout.java:75) ~[realtime-v1-0.0.1-SNAPSHOT-jar-with-dependencies.jar:?]
at org.apache.storm.daemon.executor$fn__8158$fn__8173.invoke(executor.clj:602) ~[storm-core-1.0.0.jar:1.0.0]
at org.apache.storm.util$async_loop$fn__554.invoke(util.clj:482) [storm-core-1.0.0.jar:1.0.0]
at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
at java.lang.Thread.run(Thread.java:745) [?:1.8.0_91]
14774 [Thread-19-KafkaSpout-executor[1 1]] ERROR o.a.s.util - Halting process: ("Worker died")
java.lang.RuntimeException: ("Worker died")
at org.apache.storm.util$exit_process_BANG_.doInvoke(util.clj:341) [storm-core-1.0.0.jar:1.0.0]
at clojure.lang.RestFn.invoke(RestFn.java:423) [clojure-1.7.0.jar:?]
at org.apache.storm.daemon.worker$fn__8827$fn__8828.invoke(worker.clj:758) [storm-core-1.0.0.jar:1.0.0]
at org.apache.storm.daemon.executor$mk_executor_data$fn__8046$fn__8047.invoke(executor.clj:271) [storm-core-1.0.0.jar:1.0.0]
at org.apache.storm.util$async_loop$fn__554.invoke(util.clj:494) [storm-core-1.0.0.jar:1.0.0]
at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
at java.lang.Thread.run(Thread.java:745) [?:1.8.0_91]
13660 [Thread-9] INFO o.a.s.config - SET worker-user 741ffc04-f217-41e7-b942-490c1895e7d7
14512 [Thread-21-__system-executor[-1 -1]] INFO o.a.s.d.executor - Preparing bolt __system:(-1)
14536 [Thread-21-__system-executor[-1 -1]] INFO o.a.s.d.executor - Prepared bolt __system:(-1)
14553 [Thread-15-StoreToRedisBolt-executor[2 2]] INFO o.a.s.d.executor - Preparing bolt StoreToRedisBolt:(2)
14588 [Thread-19-KafkaSpout-executor[1 1]] INFO o.a.s.d.executor - Opening spout KafkaSpout:(1)
14597 [Thread-17-__acker-executor[3 3]] INFO o.a.s.d.executor - Preparing bolt __acker:(3)
14608 [Thread-17-__acker-executor[3 3]] INFO o.a.s.d.executor - Prepared bolt __acker:(3)
14635 [Thread-15-StoreToRedisBolt-executor[2 2]] INFO o.a.s.d.executor - Prepared bolt StoreToRedisBolt:(2)
14709 [Thread-19-KafkaSpout-executor[1 1]] ERROR o.a.s.util - Async loop died!
java.lang.NoSuchMethodError: com.google.common.cache.CacheBuilder.build()Lcom/google/common/cache/Cache;
at org.apache.curator.framework.imps.NamespaceWatcherMap.<init>(NamespaceWatcherMap.java:33) ~[realtime-v1-0.0.1-SNAPSHOT-jar-with-dependencies.jar:?]
at org.apache.curator.framework.imps.CuratorFrameworkImpl.<init>(CuratorFrameworkImpl.java:81) ~[realtime-v1-0.0.1-SNAPSHOT-jar-with-dependencies.jar:?]
at org.apache.curator.framework.CuratorFrameworkFactory$Builder.build(CuratorFrameworkFactory.java:145) ~[realtime-v1-0.0.1-SNAPSHOT-jar-with-dependencies.jar:?]
at org.apache.curator.framework.CuratorFrameworkFactory.newClient(CuratorFrameworkFactory.java:100) ~[realtime-v1-0.0.1-SNAPSHOT-jar-with-dependencies.jar:?]
at org.apache.storm.kafka.ZkState.newCurator(ZkState.java:45) ~[realtime-v1-0.0.1-SNAPSHOT-jar-with-dependencies.jar:?]
at org.apache.storm.kafka.ZkState.<init>(ZkState.java:61) ~[realtime-v1-0.0.1-SNAPSHOT-jar-with-dependencies.jar:?]
at org.apache.storm.kafka.KafkaSpout.open(KafkaSpout.java:75) ~[realtime-v1-0.0.1-SNAPSHOT-jar-with-dependencies.jar:?]
at org.apache.storm.daemon.executor$fn__8158$fn__8173.invoke(executor.clj:602) ~[storm-core-1.0.0.jar:1.0.0]
at org.apache.storm.util$async_loop$fn__554.invoke(util.clj:482) [storm-core-1.0.0.jar:1.0.0]
at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
at java.lang.Thread.run(Thread.java:745) [?:1.8.0_91]
14712 [Thread-19-KafkaSpout-executor[1 1]] ERROR o.a.s.d.executor -
java.lang.NoSuchMethodError: com.google.common.cache.CacheBuilder.build()Lcom/google/common/cache/Cache;
at org.apache.curator.framework.imps.NamespaceWatcherMap.<init>(NamespaceWatcherMap.java:33) ~[realtime-v1-0.0.1-SNAPSHOT-jar-with-dependencies.jar:?]
at org.apache.curator.framework.imps.CuratorFrameworkImpl.<init>(CuratorFrameworkImpl.java:81) ~[realtime-v1-0.0.1-SNAPSHOT-jar-with-dependencies.jar:?]
at org.apache.curator.framework.CuratorFrameworkFactory$Builder.build(CuratorFrameworkFactory.java:145) ~[realtime-v1-0.0.1-SNAPSHOT-jar-with-dependencies.jar:?]
at org.apache.curator.framework.CuratorFrameworkFactory.newClient(CuratorFrameworkFactory.java:100) ~[realtime-v1-0.0.1-SNAPSHOT-jar-with-dependencies.jar:?]
at org.apache.storm.kafka.ZkState.newCurator(ZkState.java:45) ~[realtime-v1-0.0.1-SNAPSHOT-jar-with-dependencies.jar:?]
at org.apache.storm.kafka.ZkState.<init>(ZkState.java:61) ~[realtime-v1-0.0.1-SNAPSHOT-jar-with-dependencies.jar:?]
at org.apache.storm.kafka.KafkaSpout.open(KafkaSpout.java:75) ~[realtime-v1-0.0.1-SNAPSHOT-jar-with-dependencies.jar:?]
at org.apache.storm.daemon.executor$fn__8158$fn__8173.invoke(executor.clj:602) ~[storm-core-1.0.0.jar:1.0.0]
at org.apache.storm.util$async_loop$fn__554.invoke(util.clj:482) [storm-core-1.0.0.jar:1.0.0]
at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
at java.lang.Thread.run(Thread.java:745) [?:1.8.0_91]
14774 [Thread-19-KafkaSpout-executor[1 1]] ERROR o.a.s.util - Halting process: ("Worker died")
java.lang.RuntimeException: ("Worker died")
at org.apache.storm.util$exit_process_BANG_.doInvoke(util.clj:341) [storm-core-1.0.0.jar:1.0.0]
at clojure.lang.RestFn.invoke(RestFn.java:423) [clojure-1.7.0.jar:?]
at org.apache.storm.daemon.worker$fn__8827$fn__8828.invoke(worker.clj:758) [storm-core-1.0.0.jar:1.0.0]
at org.apache.storm.daemon.executor$mk_executor_data$fn__8046$fn__8047.invoke(executor.clj:271) [storm-core-1.0.0.jar:1.0.0]
at org.apache.storm.util$async_loop$fn__554.invoke(util.clj:494) [storm-core-1.0.0.jar:1.0.0]
at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
at java.lang.Thread.run(Thread.java:745) [?:1.8.0_91]
Does anyone know what may be the problem?
Thank you for your help!
Regards,
Daniela
