-
Type:
Bug
-
Status: Resolved
-
Priority:
Major
-
Resolution: Fixed
-
Affects Version/s: 2.11.0
-
Fix Version/s: 2.13.0
-
Component/s: runner-flink
-
Labels:
The Flink runner finishes bundles as part of snapshotState. In the portable runner, it is possible that a new bundle will be started as part of finishing the bundle when the bundleFinishedCallback is invoked. This happens when the watermark advances and timers get fired.
- is related to
-
BEAM-7112 State cleanup interferes with user timer callback
-
- Resolved
-
- links to