twalthr commented on code in PR #21245:
URL: https://github.com/apache/flink/pull/21245#discussion_r1015607397
##########
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/ExecutionCheckpointingOptions.java:
##########
@@ -252,4 +255,29 @@ public class ExecutionCheckpointingOptions {
"{{.Site.BaseURL}}{{.Site.LanguagePrefix}}/docs/dev/datastream/fault-tolerance/checkpointing/#checkpointing-with-parts-of-the-graph-finished-beta",
"the important
considerations"))
.build());
+
+ /**
+ * Access to this option is officially only supported via {@link
+ * CheckpointConfig#setForceCheckpointing(boolean)}, but there is no good
reason behind this.
+ *
+ * @deprecated This will be removed once iterations properly participate
in checkpointing.
+ */
+ @Internal @Deprecated @Documentation.ExcludeFromDocumentation
+ public static final ConfigOption<Boolean> FORCE_CHECKPOINTING =
+ key("execution.checkpointing.force")
+ .booleanType()
+ .defaultValue(false)
+ .withDescription("Flag to force checkpointing in iterative
jobs.");
+
+ /**
+ * Access to this option is officially only supported via {@link
+ * CheckpointConfig#enableApproximateLocalRecovery(boolean)}, but there is
no good reason behind
+ * this.
+ */
+ @Internal @Documentation.ExcludeFromDocumentation
+ public static final ConfigOption<Boolean> APPROXIMATE_LOCAL_RECOVERY =
+ key("execution.checkpointing..approximate.local.recovery")
Review Comment:
as mentioned in the other PR, does not adhere to naming conventions and has
a typo `..`
--
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]
