Hi Team, I am using Flink operator in Application ...
# troubleshootingr
Ravi Nishant
08/14/2023, 6:17 AMHi Team, I am using Flink operator in Application mode and I am trying to figure out the operator behavior when job is in terminally failed state. I see log message below which clearly shows job status changing from
RECONCILINGFAILEDFlinkDeployment Copy code
o.a.f.k.o.l.AuditUtils [m [32m[INFO ][samplejob/samplejob-jm-ue1a] >>> Event | Info | JOBSTATUSCHANGED | Job status changed from RECONCILING to FAILEDRavi Nishant
08/14/2023, 6:20 AMFrom the source code as well, it seems that the jobs status change event should propagate to update kubernetes resource here - https://github.com/apache/flink-kubernetes-operator/blob/main/flink-kubernetes-ope[…]pache/flink/kubernetes/operator/observer/JobStatusObserver.java
But this does not seem to be happening
g
Gyula Fóra
08/14/2023, 7:09 AMThere seems to be some nullpointer error somwhere, can you check the opeartor logs?
👀 1
r
Ravi Nishant
08/14/2023, 7:41 AMI could not find any reference to
NullPointerException Copy code
[m[33m2023-08-14 06:02:40,028[m [36mo.a.f.k.o.o.JobStatusObserver [m [1;31m[ERROR][hubblederivedeventsjob/hubblederivedeventsjob-jm-ue1a] Job 5c8133740a6e7c5c08492d05d56963b4 failed with error: org.apache.flink.client.program.ProgramInvocationException: An error occurred while invoking the program's main method: 'com.fasterxml.jackson.core.io.ContentReference com.fasterxml.jackson.dataformat.yaml.YAMLFactory._createContentReference(java.lang.Object)Ravi Nishant
08/14/2023, 8:12 AMThis possibly could be thrown from here which translates to setting
NullPointerReconciliationExceptionRavi Nishant
08/14/2023, 8:27 AMIn any case, should'nt the FlinkDeployment resource status should be marked as
FailedRavi Nishant
08/14/2023, 8:31 AMThe expectation is that if
FlinkDeploymentRECONCILING4 Views