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
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
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
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
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
>
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,
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.
>
>
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
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