[
https://issues.apache.org/jira/browse/FLINK-5093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Liu updated FLINK-5093:
----------------------------
Description:
In stop method of TimerService, 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)
was:
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)
> 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 TimerService, 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)
