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

Reply via email to