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

• Type: Sub-task
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: API / DataStream, Runtime / Checkpointing
• Assignee: Unassigned
• Reporter: Yun Gao
• Created: 22/Jan/21 03:59
• Updated: 22/Jan/21 04:03

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.