Bulk Operation

FLINK-2491 Log improvement for aborting checkpoint due to tasks are finishing

FLINK-2491 Document FLIP-147 capabiliites and limitations

FLINK-2491 CheckpointBarrierHandler may skip the markAlignmentStart for alignment -with-timeout checkpoint

FLINK-2491 Upgrade the TwoPhaseCommitSink to support empty transaction after finished

FLINK-2491 Do not resume channels if the barrier is received via RPC

FLINK-2491 Fix the concurrent problem between triggering savepoint with drain and finish

FLINK-2491 Verify the final checkpoint and stop-with-savepoint --drain

FLINK-2491 Respect the finished flag when extracting operator states due to skip in-flight data

FLINK-2491 Bypass operators when advanceToEndOfEventTime for both legacy and new source tasks

FLINK-2491 Double check if non-keyed FullyFinishedOperatorState can be mixed up with non finished OperatorState on recovery

FLINK-2491 FLIP-147 Checkpoint N has not been started at all

FLINK-2491 FLIP-147: Unable to recover after source fully finished

FLINK-2491 notifyCheckpointComplete without corresponding snapshotState

FLINK-2491 When task is finishedOnRestore Operators shouldn't be used

FLINK-2491 Pass watermarks in finishedOnRestore tasks

FLINK-2491 Trigger global failover for synchronous savepoints on CheckpointCoordinator

FLINK-2491 Call StreamOperator#finish on EndOfData

FLINK-2491 Check for illegal modifications of JobGraph with partially finished operators

FLINK-2491 Handle BroadcastState with finished operators

FLINK-2491 Do not create transaction in TwoPhaseCommitSinkFunction after finish()

FLINK-2491 Add a global flag for enabling/disabling final checkpoints

FLINK-2491 Take snapshots for operator coordinators which all corresponding tasks finished

FLINK-2491 Wait for a checkpoint completed after finishing a task

FLINK-2491 Add finish method to the SinkFunction

FLINK-2491 Check for illegal modifications of JobGraph with finished operators

FLINK-2491 Deprecate/Remove StreamOperator#dispose method

FLINK-2491 Decline Checkpoint if some tasks finished before get triggered

FLINK-2491 Stores finished status for fully finished operators

FLINK-2491 Add E2E/ITCase test for checkpoints after tasks finished

FLINK-2491 Skip the execution of the fully finished operators after recovery

FLINK-2491 CheckpointCoordinator pass the flag about whether a operator is fully finished on recovery

FLINK-2491 StreamTask waits for all the asynchronous step of pending checkpoint to finish

FLINK-2491 Support checkpoint alignment with finished input channels

FLINK-2491 Refactor StreamTask hierarchy to support triggering checkpoint via RPC for non-source tasks

FLINK-2491 Allows tasks to report finish state

FLINK-2491 Re-compute tasks to trigger when tasks get triggered before finished

FLINK-2491 Handle UnionListState with finished operators

FLINK-2491 Modify the logic of computing tasks to trigger/wait/commit to consider finished tasks

FLINK-2491 Refactor the CheckpointCoordinator to compute the tasks to trigger/wait/commit dynamically