gyfora commented on code in PR #403:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/403#discussion_r996327486
##########
flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/decorators/CmdStandaloneJobManagerDecorator.java:
##########
@@ -80,9 +80,14 @@ private List<String> getApplicationClusterArgs() {
}
Boolean allowNonRestoredState =
kubernetesJobManagerParameters.getAllowNonRestoredState();
- if (allowNonRestoredState != null) {
+ if (allowNonRestoredState != null && allowNonRestoredState) {
args.add("--allowNonRestoredState");
- args.add(allowNonRestoredState.toString());
+ }
+
+ String savepointPath =
kubernetesJobManagerParameters.getSavepointPath();
+ if (savepointPath != null) {
+ args.add("--fromSavepoint");
+ args.add(savepointPath);
Review Comment:
What I meant with my other question is actually why we need this part here
:)
Seems like before this change the savepoint restore logic worked correctly
so the config is probably enough.
Wouldn't be enough to simply fix the allowNonRestoredState logic to not put
true/false there?
--
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: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
