Details
-
Sub-task
-
Status: Closed
-
Major
-
Resolution: Implemented
-
None
Description
We should write an E2e test for the feature. The corner cases should include:
- must check for committing side effects (notifyCheckpointComplete() was called)
- BroadcastState
- both non keyed followed by keyed exchanges?
- aligned/unaligned checkpoints? (with unaligned checkpoint keyed operators/subtasks can be partially finished, which is very very rare in aligned checkpoints) - maybe it’s good enough to test only unaligned checkpoints.
Attachments
Issue Links
- causes
-
FLINK-24331 PartiallyFinishedSourcesITCase fails with "No downstream received 0 from xxx;"
-
- Closed
-
- is blocked by
-
FLINK-23808 Bypass operators when advanceToEndOfEventTime for both legacy and new source tasks
-
- Closed
-
-
FLINK-13973 Checkpoint recovery failed after user set uidHash
-
- Closed
-
-
FLINK-23811 Handle finished subtasks in CommonTestUtils.waitForAllTaskRunning
-
- Closed
-
- links to
(2 links to)