[FLINK-21089] Skip the execution of the fully finished operators after recovery

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Implemented
• Component/s: API / DataStream, Runtime / Checkpointing
• Labels: pull-request-available
• Assignee: Yun Gao
• Reporter: Yun Gao
• Created: 22/Jan/21 03:59
• Updated: 14/Dec/21 09:05
• Resolved: 15/Jul/21 07:44

Description

After recovery we should skip the execution of fully finished operators to keep consistent:

1. For sources (including legacy source and new source), they should directly emit EndOfPartition.
2. For both source and non-source operators, their lifecycle methods like open/endOfInput/close should be skipped.

Issue Links

• links to: GitHub Pull Request #16184