Hi Sigalit,

This could be related to https://issues.apache.org/jira/browse/FLINK-27889
We have fixed this issue already (after the release), you could simply use
the latest operator image from of `release-1.0:


*ghcr.io/apache/flink-kubernetes-operator:cc8207c
<http://ghcr.io/apache/flink-kubernetes-operator:cc8207c>*
In any case there probably was some error during the initial deployment of
your job, and the operator could not record the deployment information in
the CR status correctly.
This should not happen normally.

Cheers,
Gyula

On Tue, Jun 14, 2022 at 6:09 AM Sigalit Eliazov <e.siga...@gmail.com> wrote:

> after few hours of running job manager and task manager generated using
> the operator
> i get the following message in the operator log
> There really wasn't any traffic and the flink deployment is being delete
>
> =========================== Finished metrics report
> ===========================
> Deleting FlinkDeployment
> 2022-06-14 03:09:51,847 i.j.o.p.e.ReconciliationDispatcher
> [ERROR][ns/job-namel] Error during event processing ExecutionScope{
> resource id: CustomResourceID{name='job-name', namespace='ns'}, version:
> 53138} 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)
>
> i'm not sure I understand this behviour.
> Thanks
> Sigalit
>

Reply via email to