[ 
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)

Reply via email to