[jira] [Created] (FLINK-28755) Error when switching from stateless to savepoint upgrade mode

["Gyula Fora (Jira)" <ji...@apache.org>]

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)