Github user HeartSaVioR commented on the pull request:
https://github.com/apache/storm/pull/1322#issuecomment-207319131
You got me. :)
I was also finding aggregation metrics on worker side, but after struggling
I gave it.
Why I gave is that IMetric.getValueAndReset() is not multi-threads
friendly. Currently metrics are updated at receive queue handler thread of
executors, and that thread also handles metrics tick tuple so there's no race
condition.
Maybe most way of in process aggregation should resolve this issue.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
