[FLINK-23408] Wait for a checkpoint completed after finishing a task

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.14.0
• Component/s: Runtime / Checkpointing, Runtime / Task
• Labels: pull-request-available
• Assignee: Dawid Wysakowicz
• Reporter: Dawid Wysakowicz
• Created: 16/Jul/21 10:30
• Updated: 04/Jan/23 13:01
• Resolved: 10/Aug/21 21:25

Description

Before finishing a task we should wait for a checkpoint issued after finish() to commit all pending transactions created from the finish() method.

Issue Links

• causes: FLINK-24300 MultipleInputOperator is running much more slowly in TPCDS
• links to: Github PR #16761
• links to: GitHub Pull Request #16589
• links to: GitHub Pull Request #16713
• links to: GitHub Pull Request #16734
• links to: GitHub Pull Request #16762