[
https://issues.apache.org/jira/browse/FLINK-40465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-40465.
------------------------------
Fix Version/s: kubernetes-operator-1.16.0
Resolution: Fixed
merged to main 3ed982e5cf2e4259aa0836a0b3fb8d902ac03632
> Flink 2.0 job configuration response cannot be parsed by the operator
> ---------------------------------------------------------------------
>
> Key: FLINK-40465
> URL: https://issues.apache.org/jira/browse/FLINK-40465
> Project: Flink
> Issue Type: Bug
> Components: Kubernetes Operator
> Reporter: Mate Czagany
> Priority: Major
> Labels: pull-request-available
> Fix For: kubernetes-operator-1.16.0
>
>
> The operator currently uses `JobConfigInfo` of Flink 1.20 to deserialize the
> results of `/jobs/:jobid/config` since FLINK-35746 but Flink 2.0 removed the
> required `execution-mode` field, which causes deserialization errors,
> repeated REST queries, then a timeout.
>
> {code:java}
> o.a.f.r.r.RestClient [ERROR] Received response was neither of the expected
> type
> ([simple type, class org.apache.flink.runtime.rest.messages.JobConfigInfo])
> nor an error.
> Response=JsonResponse{json={"jid":"...","name":"State machine job",
> "execution-config":{"restart-strategy":"Cluster level default restart
> strategy",
> "job-parallelism":1,"object-reuse-mode":false,"user-config":{}}},
> httpResponseStatus=200 OK}o.a.f.k.o.s.AbstractFlinkService
> [ERROR][default/basic-example] Failed to fetch job configuration
> java.util.concurrent.TimeoutException
> at java.util.concurrent.CompletableFuture.timedGet
> at
> o.a.f.k.o.service.AbstractFlinkService.getJobConfiguration(AbstractFlinkService.java:1004)
> at
> o.a.f.k.o.service.AbstractFlinkService.getRuntimeConfiguration(AbstractFlinkService.java:947)
> at
> o.a.f.k.o.observer.JobStatusObserver.fetchAndCacheRuntimeConfig(JobStatusObserver.java:134)
> at o.a.f.k.o.observer.JobStatusObserver.observe(JobStatusObserver.java:94)
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
