Github user tammymendt commented on the pull request:
https://github.com/apache/flink/pull/605#issuecomment-138906837
I rebased with master and included the new clone() method. I had to include
extra conditionals that check whether count distinct or heavy hitters are being
tracked because otherwise the clone method would throw an exception in some
cases in which it shouldn't. Also, I added some tests to the
OperatorStatsAccumulatorTest class because I realized that I had not written
tests for different configurations of the OperatorStatsConfig class.
---
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 infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
