[ 
https://issues.apache.org/jira/browse/FLINK-38479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Gyula Fora closed FLINK-38479.
------------------------------
    Fix Version/s: kubernetes-operator-1.14.0
         Assignee: Attila Mészáros
       Resolution: Fixed

merged to main 70489d9376a7216f76c3887abd48a85deb05cebb

> Problems after upgrading the operator from 1.12.1 to 1.13.0
> -----------------------------------------------------------
>
>                 Key: FLINK-38479
>                 URL: https://issues.apache.org/jira/browse/FLINK-38479
>             Project: Flink
>          Issue Type: Bug
>          Components: Kubernetes Operator
>    Affects Versions: 1.13.0
>            Reporter: fallenup
>            Assignee: Attila Mészáros
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: kubernetes-operator-1.14.0
>
>
> FlinkSessionJobs
> 1)
> {code:java}
> 2025-09-30 09:10:45,230 i.j.o.p.e.EventProcessor [WARN ] 
> ][data-processing/005-clickhouse-research-orders-reals] Uncaught error during 
> event processing ExecutionScope{ resource id: 
> ResourceID{name='005-clickhouse-research-orders-reals', 
> namespace='data-processing'}, version: 1347467883} - but another 
> reconciliation will be attempted because a superseding event has been 
> received or another retry attempt is pending. 
> org.apache.flink.kubernetes.operator.exception.ReconciliationException: 
> java.lang.NullPointerException: Cannot invoke 
> "org.apache.flink.kubernetes.operator.api.spec.ConfigObjectNode.asFlatMap()" 
> because "leftField" is null at 
> org.apache.flink.kubernetes.operator.controller.FlinkSessionJobController.reconcile(FlinkSessionJobController.java:120)
>  at 
> org.apache.flink.kubernetes.operator.controller.FlinkSessionJobController.reconcile(FlinkSessionJobController.java:56)
>  at 
> io.javaoperatorsdk.operator.processing.Controller$1.execute(Controller.java:161)
>  at 
> io.javaoperatorsdk.operator.processing.Controller$1.execute(Controller.java:117)
>  at 
> org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics.timeControllerExecution(OperatorJosdkMetrics.java:81)
>  at 
> io.javaoperatorsdk.operator.processing.Controller.reconcile(Controller.java:116)
>  at 
> io.javaoperatorsdk.operator.processing.event.ReconciliationDispatcher.reconcileExecution(ReconciliationDispatcher.java:153)
>  at 
> io.javaoperatorsdk.operator.processing.event.ReconciliationDispatcher.handleReconcile(ReconciliationDispatcher.java:130)
>  at 
> io.javaoperatorsdk.operator.processing.event.ReconciliationDispatcher.handleDispatch(ReconciliationDispatcher.java:97)
>  at 
> io.javaoperatorsdk.operator.processing.event.ReconciliationDispatcher.handleExecution(ReconciliationDispatcher.java:68)
>  at 
> io.javaoperatorsdk.operator.processing.event.EventProcessor$ReconcilerExecutor.run(EventProcessor.java:475)
>  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.NullPointerException: Cannot invoke 
> "org.apache.flink.kubernetes.operator.api.spec.ConfigObjectNode.asFlatMap()" 
> because "leftField" is null at 
> org.apache.flink.kubernetes.operator.reconciler.diff.ReflectiveDiffBuilder.appendFields(ReflectiveDiffBuilder.java:89)
>  at 
> org.apache.flink.kubernetes.operator.reconciler.diff.ReflectiveDiffBuilder.build(ReflectiveDiffBuilder.java:78)
>  at 
> org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler.reconcile(AbstractFlinkResourceReconciler.java:138)
>  at 
> org.apache.flink.kubernetes.operator.controller.FlinkSessionJobController.reconcile(FlinkSessionJobController.java:117)
>  ... 13 more{code}
> 2)
> {code:java}
> 2025-09-30 09:35:30,140 i.j.o.p.e.EventProcessor [WARN 
> ][data-processing/pyflink-to-outbox] Uncaught error during event processing 
> ExecutionScope{ resource id: ResourceID{name='pyflink-to-outbox', 
> namespace='data-processing'}, version: 1347486671} - but another 
> reconciliation will be attempted because a superseding event has been 
> received or another retry attempt is pending. 
> org.apache.flink.kubernetes.operator.exception.ReconciliationException: 
> java.lang.NullPointerException at 
> org.apache.flink.kubernetes.operator.controller.FlinkSessionJobController.reconcile(FlinkSessionJobController.java:120)
>  at 
> org.apache.flink.kubernetes.operator.controller.FlinkSessionJobController.reconcile(FlinkSessionJobController.java:56)
>  at 
> io.javaoperatorsdk.operator.processing.Controller$1.execute(Controller.java:161)
>  at 
> io.javaoperatorsdk.operator.processing.Controller$1.execute(Controller.java:117)
>  at 
> org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics.timeControllerExecution(OperatorJosdkMetrics.java:81)
>  at 
> io.javaoperatorsdk.operator.processing.Controller.reconcile(Controller.java:116)
>  at 
> io.javaoperatorsdk.operator.processing.event.ReconciliationDispatcher.reconcileExecution(ReconciliationDispatcher.java:153)
>  at 
> io.javaoperatorsdk.operator.processing.event.ReconciliationDispatcher.handleReconcile(ReconciliationDispatcher.java:130)
>  at 
> io.javaoperatorsdk.operator.processing.event.ReconciliationDispatcher.handleDispatch(ReconciliationDispatcher.java:97)
>  at 
> io.javaoperatorsdk.operator.processing.event.ReconciliationDispatcher.handleExecution(ReconciliationDispatcher.java:68)
>  at 
> io.javaoperatorsdk.operator.processing.event.EventProcessor$ReconcilerExecutor.run(EventProcessor.java:475){code}
>  



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to