Details
-
Sub-task
-
Status: Closed
-
Major
-
Resolution: Implemented
-
None
-
None
Description
After recovery we should skip the execution of fully finished operators to keep consistent:
- For sources (including legacy source and new source), they should directly emit EndOfPartition.
- For both source and non-source operators, their lifecycle methods like open/endOfInput/close should be skipped.
Attachments
Issue Links
- links to