Maximilian Michels created BEAM-9161:
----------------------------------------
Summary: Concurrent close of ActiveBundle from main and bundle
timer thread
Key: BEAM-9161
URL: https://issues.apache.org/jira/browse/BEAM-9161
Project: Beam
Issue Type: Bug
Components: runner-flink
Reporter: Maximilian Michels
Assignee: Maximilian Michels
The issue results in exceptions like "Already closed" due to a concurrent close
of the remote input receivers from (1) the main thread and (2) the thread for
finishing the bundle. In combination with the {{bundleFinishedCallback}} it may
have also caused a slowdown due to closing a bundle when it was not needed.
We should make sure that only one thread at a time can start or finish a bundle.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
