Alexis Sarda-Espinosa created FLINK-30638:
---------------------------------------------
Summary: Operator doesn't forward allowNonRestoredState flag
Key: FLINK-30638
URL: https://issues.apache.org/jira/browse/FLINK-30638
Project: Flink
Issue Type: Bug
Components: Kubernetes Operator
Affects Versions: kubernetes-operator-1.3.1
Reporter: Alexis Sarda-Espinosa
Attachments: flink-kubernetes-operator_json.txt
My Flink image is currently based on 1.15, and I have HA enabled. After an
upgrade where I removed some transformations from the pipeline, I see the
following exception in the deployec Flink cluster:
Job 38585f46d840b3c2e9f843e230398d35 reached terminal state FAILED.
org.apache.flink.runtime.client.JobInitializationException: Could not start the
JobMaster.
...
Caused by: java.util.concurrent.CompletionException:
java.lang.IllegalStateException: There is no operator for the state
d3bab17db5b56f81eb48b3e7d5cce15d
I'm attaching some of the operator's logs, but I don't see anything strange
there.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
