Export - CSV (All fields)
Export - CSV (Current fields)
FLINK-24266
Log improvement for aborting checkpoint due to tasks are finishing
Document FLIP-147 capabiliites and limitations
CheckpointBarrierHandler may skip the markAlignmentStart for alignment -with-timeout checkpoint
Upgrade the TwoPhaseCommitSink to support empty transaction after finished
Do not resume channels if the barrier is received via RPC
Fix the concurrent problem between triggering savepoint with drain and finish
Verify the final checkpoint and stop-with-savepoint --drain
Respect the finished flag when extracting operator states due to skip in-flight data
Bypass operators when advanceToEndOfEventTime for both legacy and new source tasks
Double check if non-keyed FullyFinishedOperatorState can be mixed up with non finished OperatorState on recovery
FLIP-147 Checkpoint N has not been started at all
FLIP-147: Unable to recover after source fully finished
notifyCheckpointComplete without corresponding snapshotState
When task is finishedOnRestore Operators shouldn't be used
Pass watermarks in finishedOnRestore tasks
Trigger global failover for synchronous savepoints on CheckpointCoordinator
Call StreamOperator#finish on EndOfData
Check for illegal modifications of JobGraph with partially finished operators
Handle BroadcastState with finished operators
Do not create transaction in TwoPhaseCommitSinkFunction after finish()
Add a global flag for enabling/disabling final checkpoints
Take snapshots for operator coordinators which all corresponding tasks finished
Wait for a checkpoint completed after finishing a task
Add finish method to the SinkFunction
Check for illegal modifications of JobGraph with finished operators
Deprecate/Remove StreamOperator#dispose method
Decline Checkpoint if some tasks finished before get triggered
Stores finished status for fully finished operators
Add E2E/ITCase test for checkpoints after tasks finished
Skip the execution of the fully finished operators after recovery
CheckpointCoordinator pass the flag about whether a operator is fully finished on recovery
StreamTask waits for all the asynchronous step of pending checkpoint to finish
Support checkpoint alignment with finished input channels
Refactor StreamTask hierarchy to support triggering checkpoint via RPC for non-source tasks
Allows tasks to report finish state
Re-compute tasks to trigger when tasks get triggered before finished
Handle UnionListState with finished operators
Modify the logic of computing tasks to trigger/wait/commit to consider finished tasks
Refactor the CheckpointCoordinator to compute the tasks to trigger/wait/commit dynamically