Gyula Fora created FLINK-28755:
----------------------------------
Summary: Error when switching from stateless to savepoint upgrade
mode
Key: FLINK-28755
URL: https://issues.apache.org/jira/browse/FLINK-28755
Project: Flink
Issue Type: Bug
Components: Kubernetes Operator
Affects Versions: kubernetes-operator-1.1.0, kubernetes-operator-1.2.0
Reporter: Gyula Fora
When using the savepoint upgrade mode the state.savepoints.dir currently comes
from the currently deployed spec / config.
This causes a nullpointer exception when switching to savepoint upgrade mode
from stateless if state.savepoints.dir was previously undefined:
{noformat}
org.apache.flink.util.Preconditions.checkNotNull(Preconditions.java:59)
org.apache.flink.kubernetes.operator.service.AbstractFlinkService.cancelJob(AbstractFlinkService.java:279)
org.apache.flink.kubernetes.operator.service.NativeFlinkService.cancelJob(NativeFlinkService.java:93)
org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler.cancelJob(ApplicationReconciler.java:172)
org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler.cancelJob(ApplicationReconciler.java:52)
org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler.reconcileSpecChange(AbstractJobReconciler.java:108)
org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler.reconcile(AbstractFlinkResourceReconciler.java:148)
org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler.reconcile(AbstractFlinkResourceReconciler.java:56)
org.apache.flink.kubernetes.operator.controller.FlinkDeploymentController.reconcile(FlinkDeploymentController.java:115){noformat}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
