Flink-Kubernetes-operator error.

Mon, 27 Jun 2022 19:06:05 -0700 

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)

回复