[jira] [Created] (FLINK-5093) java.util.ConcurrentModificationException is thrown when stopping TimerService

[Shang Yuanchun (Jira)]

Biao Liu created FLINK-5093:
-------------------------------

             Summary: java.util.ConcurrentModificationException is thrown when stopping TimerService
                 Key: FLINK-5093
                 URL: https://issues.apache.org/jira/browse/FLINK-5093
             Project: Flink
          Issue Type: Bug
          Components: Cluster Management
         Environment: FLIP-6 feature branch
            Reporter: Biao Liu
            Assignee: Biao Liu
            Priority: Minor


In stop method of TimeService, removing Timeout instance while iterating the map will cause a java.util.ConcurrentModificationException.

The stack is:
java.util.ConcurrentModificationException
        at java.util.HashMap$HashIterator.nextEntry(HashMap.java:922)
        at java.util.HashMap$KeyIterator.next(HashMap.java:956)
        at org.apache.flink.runtime.taskexecutor.slot.TimerService.stop(TimerService.java:63)
        at org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable.stop(TaskSlotTable.java:129)
        at org.apache.flink.runtime.taskexecutor.TaskExecutor.shutDown(TaskExecutor.java:224)
        at org.apache.flink.runtime.taskexecutor.TaskManagerRunner.shutDownInternally(TaskManagerRunner.java:135)
        at org.apache.flink.runtime.taskexecutor.TaskManagerRunner.shutDown(TaskManagerRunner.java:129)
        at org.apache.flink.runtime.minicluster.MiniCluster.shutdownInternally(MiniCluster.java:319)
        at org.apache.flink.runtime.minicluster.MiniCluster.shutdown(MiniCluster.java:274)



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)