storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Adrien Carreira <...@reportlinker.com>
Subject Re: Bug in MetricConsumer
Date Fri, 13 Jan 2017 08:33:10 GMT
I've set up storm.local.hostname on storm.yaml that is used for nimbus and
supervisor. I've just removed this one, restarted nimbus and all supervisor
and it's working :D

I will submit a bug :-)

2017-01-12 17:54 GMT+01:00 Jungtaek Lim <kabhwan@gmail.com>:

> Did you set up storm.local.hostname only for storm clusters, or also the
> node you're submitting jar from?
>
> Anyway I think this is not intended behavior (a bug).
> Could you file an issue to JIRA? https://issues.apache.org/
> jira/browse/STORM
> Please let me know if you want me to file this instead.
>
> Thanks,
> Jungtaek Lim (HeartSaVioR)
>
> 2017년 1월 13일 (금) 오전 1:36, Adrien Carreira <aca@reportlinker.com>님이
작성:
>
>> You are right, My topology config contains :
>> storm.local.hostname
>>
>> "crwl-agent1"
>>
>>
>> But why ? I haven't set up this value, just in each storm.yaml, because
>> either I see localhost insteed of the hostname...
>>
>> 2017-01-12 10:26 GMT+01:00 Jungtaek Lim <kabhwan@gmail.com>:
>>
>> Hi Adrien,
>>
>> could you check topology config has 'storm.local.hostname'?
>> srcWorkerHost uses the value of 'storm.local.hostname' if available. It's
>> intended to read that value for each node but there might be edge case like
>> reading topology config instead of node's config value.
>>
>> Thanks,
>> Jungtaek Lim (HeartSaVioR)
>>
>> 2017년 1월 12일 (목) 오후 5:24, Adrien Carreira <aca@reportlinker.com>님이
작성:
>>
>> Nope :/
>>
>>
>>
>> 2017-01-11 18:28 GMT+01:00 Jacob Johansen <johansenjuwp@gmail.com>:
>>
>>
>>
>> Do you have the hostname on all the supervisors machines named the same?
>>
>> On January 11, 2017 at 10:30:03 AM, Adrien Carreira (aca@reportlinker.com)
>> wrote:
>>
>> Hi Guys,
>>
>> I'm running a topology on 3 supervisor. I've registred a custom
>> MetricsConsumer class that output metrics on Elasticsearch.
>>
>> My bug is that the taskInfo.srcWorkerHost that always the same values as
>> the first supervisor (nimbus as well), Even when I put a parallelismHint to
>> 3...
>>
>> I'm using storm 1.0.2
>>
>> Thanks for your feedback
>>
>>
>>
>>

Mime
View raw message