[
https://issues.apache.org/jira/browse/FLINK-4833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15581973#comment-15581973
]
Maximilian Michels commented on FLINK-4833:
-------------------------------------------
I think this occurs when the TaskManager snapshots the state of the operator
statistics operator concurrently with values being added.
The underlying exception in {{CountMinHeavyHitter.merge(..)}} is not properly
forwarded. This could be improved in the code operator statistics code. The
concurrent modification of snapshotting / accumulator modification can only be
solved by FLINK-4829.
> Unstable test
> OperatorStatsAccumulatorTest.testAccumulatorHeavyHitterCountMinSketch
> -----------------------------------------------------------------------------------
>
> Key: FLINK-4833
> URL: https://issues.apache.org/jira/browse/FLINK-4833
> Project: Flink
> Issue Type: Bug
> Components: Tests
> Reporter: Kostas Kloudas
> Labels: test-stability
>
> Some instances:
> view-source:https://s3.amazonaws.com/archive.travis-ci.org/jobs/167801187/log.txt
> view-source:https://s3.amazonaws.com/archive.travis-ci.org/jobs/167801191/log.txt
> view-source:https://s3.amazonaws.com/archive.travis-ci.org/jobs/167801193/log.txt
> view-source:https://s3.amazonaws.com/archive.travis-ci.org/jobs/167801195/log.txt
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)