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

Reply via email to