dawidwys commented on a change in pull request #18024:
URL: https://github.com/apache/flink/pull/18024#discussion_r764632416
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/SavepointConfigOptions.java
##########
@@ -46,4 +46,14 @@
.withDescription(
"Allow to skip savepoint state that cannot be
restored. "
+ "Allow this if you removed an operator
from your pipeline after the savepoint was triggered.");
+ /**
+ * Describes the mode how Flink should restore from the given savepoint or
retained checkpoint.
+ */
+ public static final ConfigOption<RestoreMode> RESTORE_MODE =
+ key("execution.savepoint-restore-mode")
+ .enumType(RestoreMode.class)
+ .defaultValue(RestoreMode.NO_CLAIM)
+ .withDescription(
+ "Describes the mode how Flink should restore from
the given"
+ + " savepoint or retained checkpoint.");
Review comment:
I intentionally did not want to describe it yet, because the `NO_CLAIM`
mode is not implemented in this PR, as described in the FLIP.
However, it made me think that it's probably a better approach to have the
`LEGACY` mode explicitly at least at this point in time. Therefore I renamed
`NO_CLAIM` to `LEGACY` and extended the description a bit.
--
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]
