azagrebin opened a new pull request #13511: URL: https://github.com/apache/flink/pull/13511
`SharedSlot#release` releases all logical slots in a loop over their collection. The logical slot releases lead to their execution failures. This can cause cancellation of other executions sharing same slot. The execution failure can cause cancelation of other sharing executions by `Scheduler`. The canceled executions subsequently call `SharedSlot#returnLogicalSlot` which modifies the logical slot collection while it is being iterated in `SharedSlot#release`, if the canceled executions share the same slot. This leads to `ConcurrentModificationException` of the logical slot collection in `SharedSlot` while looping it in the `SharedSlot#release` call. To avoid the `ConcurrentModificationException`, the logical slot collection can be copied before iterating it. ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected]
