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)