Nicolaus Weidner created FLINK-24987:
----------------------------------------
Summary: Enhance ExternalizedCheckpointCleanup enum
Key: FLINK-24987
URL: https://issues.apache.org/jira/browse/FLINK-24987
Project: Flink
Issue Type: Improvement
Components: API / DataStream
Affects Versions: 1.14.0
Reporter: Nicolaus Weidner
We use the config setting
[execution.checkpointing.externalized-checkpoint-retention|https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/ExecutionCheckpointingOptions.java#L90-L119]
to distinguish three cases:
- delete on cancellation
- retain on cancellation
- no externalized checkpoints (if no value is set)
It would be easier to understand if we had an explicit enum value
NO_EXTERNALIZED_CHECKPOINTS for the third case in
[ExternalizedCheckpointCleanup|https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/CheckpointConfig.java#L702-L742].
This would also avoid potential issues for clients with handling null values
(for example, null values being dropped on serialization could be annoying when
trying to change from RETAIN_ON_CANCELLATION to no external checkpoints).
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
