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 <[email protected]>님이 작성: > 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 <[email protected]>: > > 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 <[email protected]>님이 작성: > > Nope :/ > > > > 2017-01-11 18:28 GMT+01:00 Jacob Johansen <[email protected]>: > > > > Do you have the hostname on all the supervisors machines named the same? > > On January 11, 2017 at 10:30:03 AM, Adrien Carreira ([email protected]) > 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 > > > >
