ryanvanhuuksloot commented on code in PR #25899:
URL: https://github.com/apache/flink/pull/25899#discussion_r1915210703
##########
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointProperties.java:
##########
@@ -283,6 +293,39 @@ public String toString() {
false, // Retain on suspension
false);
+ private static final CheckpointProperties FULL_CHECKPOINT_NEVER_RETAINED =
+ new CheckpointProperties(
+ false,
+ CheckpointType.FULL_CHECKPOINT,
+ true,
+ true, // Delete on success
+ true, // Delete on cancellation
+ true, // Delete on failure
+ true, // Delete on suspension
+ false);
+
+ private static final CheckpointProperties
FULL_CHECKPOINT_RETAINED_ON_FAILURE =
+ new CheckpointProperties(
+ false,
+ CheckpointType.FULL_CHECKPOINT,
+ true,
+ true, // Delete on success
+ true, // Delete on cancellation
+ false, // Retain on failure
+ true, // Delete on suspension
+ false);
+
+ private static final CheckpointProperties
FULL_CHECKPOINT_RETAINED_ON_CANCELLATION =
+ new CheckpointProperties(
+ false,
+ CheckpointType.FULL_CHECKPOINT,
+ true,
+ true, // Delete on success
+ false, // Retain on cancellation
+ false, // Retain on failure
+ false, // Retain on suspension
+ false);
+
Review Comment:
They are only used for tests
We don't really have an test suite for testing this kind of thing
I'm open to ideas for where to add tests
I've thought about
`SnapshotUtilsTest`
and
`CheckpointPropertiesTest`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
