You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by GitBox <gi...@apache.org> on 2022/02/24 15:58:57 UTC

[GitHub] [flink-kubernetes-operator] tweise commented on a change in pull request #22: [FLINK-26141] Support last-state upgrade mode

tweise commented on a change in pull request #22:
URL: https://github.com/apache/flink-kubernetes-operator/pull/22#discussion_r814026623



##########
File path: flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/FlinkService.java
##########
@@ -123,6 +127,15 @@ public void submitSessionCluster(FlinkDeployment deployment, Configuration conf)
                                     .get(1, TimeUnit.MINUTES);
                     savepointOpt = Optional.of(savepoint);
                     break;
+                case LAST_STATE:

Review comment:
       `LAST_STATE` should restore from checkpoint or savepoint, whichever is more recent.




-- 
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: commits-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org