Aitozi commented on code in PR #193:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/193#discussion_r865787685
##########
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/JobSpec.java:
##########
@@ -65,4 +65,7 @@ public class JobSpec {
/** Upgrade mode of the Flink job. */
@EqualsAndHashCode.Exclude private UpgradeMode upgradeMode =
UpgradeMode.STATELESS;
+
+ /** Allow checkpoint state that cannot be mapped to any job vertex in
tasks. */
+ @EqualsAndHashCode.Exclude private boolean allowNonRestoredState = false;
Review Comment:
I think this option only affect the next upgrade behavior whether to recover
from the unknown state mapping and do not have to trigger a direct upgrade
after user change this. So I think it should be same with the upgradeMode.
--
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]
