Flink-Kubernetes-operator error.

["Murphy, Matthew" <Ma...@T-Mobile.com>]

Hello Folks,



Having an issue with the flink-kubernetes-operator.

We are trying to delete an existing deployment in a customer namespace.



The operator doesn't seem to pick up the deletion.



I re-cycled the operator pod and see this.

Seeing this error in operator logs:

Operator Version 1.0.0
Kubernetes v1.21.6

I re-cycled the operator pod and see this.

Seeing this error in operator logs:




2022-06-27 20:19:10,561 o.a.f.k.o.i.InformerManager    [INFO ] Created session job informers for [allNamespace]

2022-06-27 20:19:10,668 o.a.f.k.o.c.FlinkDeploymentController [INFO ][supplychain-nwsc/nwsc-stream-processor-dev01] Deleting FlinkDeployment

2022-06-27 20:19:10,682 i.j.o.p.e.ReconciliationDispatcher [ERROR][supplychain-nwsc/nwsc-stream-processor-dev01] Error during event processing ExecutionScope{ resource id: CustomResourceID{name='nwsc-stream-processor-dev01', namespace='supplychain-nwsc'}, version: 53209979} failed.

java.lang.RuntimeException: Cannot create observe config before first deployment, this indicates a bug.

        at org.apache.flink.kubernetes.operator.config.FlinkConfigManager.getObserveConfig(FlinkConfigManager.java:137)

        at org.apache.flink.kubernetes.operator.service.FlinkService.cancelJob(FlinkService.java:357)

        at org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler.shutdown(ApplicationReconciler.java:327)

        at org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractDeploymentReconciler.cleanup(AbstractDeploymentReconciler.java:56)

        at org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractDeploymentReconciler.cleanup(AbstractDeploymentReconciler.java:37)

        at org.apache.flink.kubernetes.operator.controller.FlinkDeploymentController.cleanup(FlinkDeploymentController.java:107)

        at org.apache.flink.kubernetes.operator.controller.FlinkDeploymentController.cleanup(FlinkDeploymentController.java:59)

        at io.javaoperatorsdk.operator.processing.Controller$1.execute(Controller.java:68)

        at io.javaoperatorsdk.operator.processing.Controller$1.execute(Controller.java:50)

        at io.javaoperatorsdk.operator.api.monitoring.Metrics.timeControllerExecution(Metrics.java:34)

        at io.javaoperatorsdk.operator.processing.Controller.cleanup(Controller.java:49)

        at io.javaoperatorsdk.operator.processing.event.ReconciliationDispatcher.handleCleanup(ReconciliationDispatcher.java:252)

        at io.javaoperatorsdk.operator.processing.event.ReconciliationDispatcher.handleDispatch(ReconciliationDispatcher.java:72)

        at io.javaoperatorsdk.operator.processing.event.ReconciliationDispatcher.handleExecution(ReconciliationDispatcher.java:50)

        at io.javaoperatorsdk.operator.processing.event.EventProcessor$ControllerExecution.run(EventProcessor.java:349)

        at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)

        at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)

        at java.base/java.lang.Thread.run(Unknown Source)