Details
-
Technical Debt
-
Status: Open
-
Not a Priority
-
Resolution: Unresolved
-
None
-
None
Description
This came up in a review: https://github.com/apache/flink/pull/14948#discussion_r588304475
The stopWithSavepoint() methods in Flink have a boolean flag, indicating either whether we inject a MAX_WATERMARK in the pipeline, or whether we terminate or suspend a job.
As part of this ticket, I propose to introduce a new enum type in flink-core "StopWithSavepointBehavior" with SUSPEND and TERMINATE fields and replace the boolean flag with this new field.
Attachments
Issue Links
- is related to
-
FLINK-21333 Introduce stopping with savepoint state
- Closed