Supervisor failed but workers continue to work

2016-09-17 Thread k-2f...@hotmail.com
Storm UI shows this supervisor is down. But the workers run properly. The error log of failed supervisor is: 2016-09-18 09:47:13.129 o.a.s.d.supervisor [INFO] Shutting down e0c975d4-85c7-45fa-900d-bd3e7240e92c: 2016-09-18 09:47:13.129 o.a.s.config [INFO] GET worker-user 2016-09-18 09:47:13.129

Re: SpoutConfig zkRoot argument causing KafkaSpout exception

2016-09-17 Thread Ambud Sharma
Zkroot should be empty string not a /. Basically that config refers to the path where the consumer offsets will be stored. On Sep 17, 2016 12:20 AM, "Dominik Safaric" wrote: > Hi, > > I’ve set up a topology consisting of a Kafka spout. But unfortunately, I > keep

SpoutConfig zkRoot argument causing KafkaSpout exception

2016-09-17 Thread Dominik Safaric
Hi, I’ve set up a topology consisting of a Kafka spout. But unfortunately, I keep getting the exception Caused by: java.lang.IllegalArgumentException: Invalid path string "//bytes3b68b144-e13c-4de3-beed-405e3ca5ae20/partition_1" caused by empty node name specified @1. Zookeeper has the

Re: SpoutConfig zkRoot argument causing KafkaSpout exception

2016-09-17 Thread Ambud Sharma
It will refer to the root, it uses a slash by default. As you can see you have 2 in the path: *"//bytes3b68b144-e13c-4de3-**beed**-405e3ca5ae20/partition_1"* On Sep 17, 2016 12:49 AM, "Dominik Safaric" wrote: > If the value is set to an empty string, to what path

Re: SpoutConfig zkRoot argument causing KafkaSpout exception

2016-09-17 Thread Dominik Safaric
If the value is set to an empty string, to what path does it actually refer to? Dominik > On 17 Sep 2016, at 09:40, Ambud Sharma wrote: > > Zkroot should be empty string not a /. > > Basically that config refers to the path where the consumer offsets will be >

Re: Storm 1.0.2 - KafkaSpout cannot find partition information

2016-09-17 Thread Dominik Safaric
Already configured with an empty string, but unfortunately I keep getting the same message claiming no partitions can be found. Dominik Šafarić > On 17 Sep 2016, at 18:11, Ambud Sharma wrote: > > The Zkroot should be empty string. > > >> On Sep 17, 2016 9:09 AM,

Re: Storm 1.0.2 - KafkaSpout cannot find partition information

2016-09-17 Thread Ambud Sharma
I believe you are overriding the value here: spoutConfig.zkRoot = "/brokers”; On Sep 17, 2016 9:29 AM, "Dominik Safaric" wrote: > Already configured with an empty string, but unfortunately I keep getting > the same message claiming no partitions can be found. > >

Storm 1.0.2 - KafkaSpout cannot find partition information

2016-09-17 Thread Dominik Safaric
Hi, I’ve deployed a topology consisting of a KafkaSpout using Kafka 0.10.0.1 and Zookeeper 3.4.6. All of the services, including the Nimbus and Supervisor, run on the same instance. However, by examining the worker.log file, I’ve found that the KafkaSpout is unable to find partitions

Re: Storm 1.0.2 - KafkaSpout cannot find partition information

2016-09-17 Thread Ambud Sharma
The Zkroot should be empty string. On Sep 17, 2016 9:09 AM, "Dominik Safaric" wrote: > Hi, > > I’ve deployed a topology consisting of a KafkaSpout using Kafka 0.10.0.1 > and Zookeeper 3.4.6. All of the services, including the Nimbus and > Supervisor, run on the same