You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/06/04 17:26:00 UTC
[jira] [Resolved] (FLINK-27889) Error when the LastReconciledSpec is null
[ https://issues.apache.org/jira/browse/FLINK-27889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Gyula Fora resolved FLINK-27889.
--------------------------------
Assignee: Hector Miuler Malpica Gallegos
Resolution: Fixed
merged to main cd5107d7ace9d2896efde91ac0ca3c7a9226f3bc
> 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
> 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)