[ https://issues.apache.org/jira/browse/FLINK-27889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Gyula Fora updated FLINK-27889: ------------------------------- Fix Version/s: kubernetes-operator-1.0.1 > Error when the LastReconciledSpec is null > ----------------------------------------- > > Key: FLINK-27889 > URL: https://issues.apache.org/jira/browse/FLINK-27889 > Project: Flink > Issue Type: Bug > Components: Kubernetes Operator > Reporter: Hector Miuler Malpica Gallegos > Assignee: Hector Miuler Malpica Gallegos > Priority: Major > Labels: pull-request-available > Fix For: kubernetes-operator-1.1.0, kubernetes-operator-1.0.1 > > Attachments: scratch_7.json > > > My FlinkDeployment was left with erros, when he can not start correctly, the > following message: > > > {code:java} > 2022-06-01 04:36:10,070 o.a.f.k.o.r.ReconciliationUtils [WARN > ][flink-02/cosmosdb] Attempt count: 5, last attempt: true > 2022-06-01 04:36:10,072 i.j.o.p.e.ReconciliationDispatcher > [ERROR][flink-02/cosmosdb] Error during event processing ExecutionScope{ > resource id: CustomResourceID > {name='cosmosdb', namespace='flink-02'}, version: null} failed. > org.apache.flink.kubernetes.operator.exception.ReconciliationException: > java.lang.IllegalArgumentException: Only "local" is supported as schema for > application mode. This assumes that the jar is located in the image, not the > Flink client. An example of such path is: > local:///opt/flink/examples/streaming/WindowJoin.jar > at > org.apache.flink.kubernetes.operator.controller.FlinkDeploymentController.reconcile(FlinkDeploymentController.java:130) > at > org.apache.flink.kubernetes.operator.controller.FlinkDeploymentController.reconcile(FlinkDeploymentController.java:59) > at > io.javaoperatorsdk.operator.processing.Controller$2.execute(Controller.java:101) > at > io.javaoperatorsdk.operator.processing.Controller$2.execute(Controller.java:76) > at > io.javaoperatorsdk.operator.api.monitoring.Metrics.timeControllerExecution(Metrics.java:34) > at > io.javaoperatorsdk.operator.processing.Controller.reconcile(Controller.java:75) > at > io.javaoperatorsdk.operator.processing.event.ReconciliationDispatcher.reconcileExecution(ReconciliationDispatcher.java:143) > at > io.javaoperatorsdk.operator.processing.event.ReconciliationDispatcher.handleReconcile(ReconciliationDispatcher.java:109) > at > io.javaoperatorsdk.operator.processing.event.ReconciliationDispatcher.handleDispatch(ReconciliationDispatcher.java:74) > 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) > Caused by: java.lang.IllegalArgumentException: Only "local" is supported as > schema for application mode. This assumes that the jar is located in the > image, not the Flink client. An example of such path is: > local:///opt/flink/examples/streaming/WindowJoin.jar > at > org.apache.flink.kubernetes.utils.KubernetesUtils.lambda$checkJarFileForApplicationMode$2(KubernetesUtils.java:407) > at > org.apache.flink.util.function.FunctionUtils.lambda$uncheckedFunction$2(FunctionUtils.java:73) > at java.base/java.util.stream.ReferencePipeline$3$1.accept(Unknown > Source) > at java.base/java.util.Collections$2.tryAdvance(Unknown Source) > at java.base/java.util.Collections$2.forEachRemaining(Unknown Source) > at java.base/java.util.stream.AbstractPipeline.copyInto(Unknown > Source) > at > java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(Unknown Source) > at > java.base/java.util.stream.ReduceOps$ReduceOp.evaluateSequential(Unknown > Source) > at java.base/java.util.stream.AbstractPipeline.evaluate(Unknown > Source) > at java.base/java.util.stream.ReferencePipeline.collect(Unknown > Source) > at > org.apache.flink.kubernetes.utils.KubernetesUtils.checkJarFileForApplicationMode(KubernetesUtils.java:412) > at > org.apache.flink.kubernetes.KubernetesClusterDescriptor.deployApplicationCluster(KubernetesClusterDescriptor.java:206) > at > org.apache.flink.client.deployment.application.cli.ApplicationClusterDeployer.run(ApplicationClusterDeployer.java:67) > at > org.apache.flink.kubernetes.operator.service.FlinkService.submitApplicationCluster(FlinkService.java:163) > at > org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler.deployFlinkJob(ApplicationReconciler.java:283) > at > org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler.reconcile(ApplicationReconciler.java:83) > at > org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler.reconcile(ApplicationReconciler.java:58) > at > org.apache.flink.kubernetes.operator.controller.FlinkDeploymentController.reconcile(FlinkDeploymentController.java:126) > ... 13 more > 2022-06-01 04:36:10,073 i.j.o.p.e.EventProcessor > [ERROR][flink-02/cosmosdb] Exhausted retries for ExecutionScope{ resource id: > CustomResourceID{name='cosmosdb', namespace='flink-02'} > , version: null} > 2022-06-01 04:37:27,344 o.a.f.k.o.c.FlinkDeploymentController [INFO > ][flink-02/cosmosdb] Deleting FlinkDeployment > 2022-06-01 04:37:27,345 i.j.o.p.e.ReconciliationDispatcher > [ERROR][flink-02/cosmosdb] Error during event processing ExecutionScope{ > resource id: CustomResourceID > {name='cosmosdb', namespace='flink-02'}, version: 5206202} 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) > {{2022-06-01 04:37:27,345 i.j.o.p.e.EventProcessor > [ERROR][flink-02/cosmosdb] Exhausted retries for ExecutionScope{ resource id: > CustomResourceID{name='cosmosdb', namespace='flink-02'} > , version: 5206202}}} > 2022-06-01 04:40:44,540 o.a.f.k.o.c.FlinkConfigManager [INFO ] Default > configuration did not change, nothing to do... > 2022-06-01 04:40:44,848 o.a.f.m.s.Slf4jReporter [INFO ] > {code} > > > The FlinkDeployment of the example is the fallowing: [^scratch_7.json] > > > -- This message was sent by Atlassian Jira (v8.20.7#820007)