[ https://issues.apache.org/jira/browse/FLINK-27889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
ASF GitHub Bot updated FLINK-27889: ----------------------------------- Labels: pull-request-available (was: ) > 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 > Priority: Major > Labels: pull-request-available > Attachments: scratch_7.json > > > My FlinkDeployment was left with erros, when he can not start correctly, the > following message: > > {{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 ] }} > > The FlinkDeployment of the example is the fallowing: [^scratch_7.json] > > > -- This message was sent by Atlassian Jira (v8.20.7#820007)