[FLINK-23831] Verify the final checkpoint and stop-with-savepoint --drain

• Type: Sub-task
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 1.14.0
• Fix Version/s: 1.14.0
• Component/s: Runtime / Checkpointing
• Labels: release-testing
• Assignee: Yangze Guo
• Reporter: Yun Gao
• Created: 17/Aug/21 06:10
• Updated: 06/Sep/21 02:51
• Resolved: 06/Sep/21 02:51

Description

In 1.14 we support checkpoints with part of tasks finished, and based on this functionality, we further support the final checkpoint and unify the process of stop-with-savepoint --drain.

In order to test the new feature, we may need to verify:
1. Checkpoint with the finished tasks.
2. Restore from the checkpoint with finished tasks.
3. All the data are committed correctly for bounded jobs with 2pc sinks.
4. Stop-with-savepoint --drain remains correct.
5. All the above tests also work with unaligned checkpoint.