tanjialiang created FLINK-30222:
-----------------------------------
Summary: Suspended a job in last-state mode bug
Key: FLINK-30222
URL: https://issues.apache.org/jira/browse/FLINK-30222
Project: Flink
Issue Type: Bug
Components: Kubernetes Operator
Affects Versions: kubernetes-operator-1.2.0, 1.16.0
Reporter: tanjialiang
Attachments: image-2022-11-27-16-48-08-445.png
In flink 1.16.0, it support set kubernetes HA with options 'kubernetes', such
as 'high-availability: kubernetes'. But in kubernetes operator 1.2.0, I try to
suspended a job in last-state mode, it validate fail, because of 'Job could not
be upgraded with last-state while Kubernetes HA disabled'.
I try to use kubectl patch to supsended a job with last-state
{code:sh}
kubectl -nbigdata-flink patch
flinkdeployments.flink.apache.org/streaming-638223bf650ac869689faa62-flink
--type=merge -p '{"spec": {"job":
{"state": "suspended", "upgradeMode": "last-state"}{code}
it found an error, because my kubernetes HA is disabled
{code:java}
Error from server: admission webhook "flinkoperator.flink.apache.org" denied
the request: Job could not be upgraded with last-state while Kubernetes HA
disabled {code}
but i enabled kubernetes HA with this follow options:
{code:yaml}
kubernetes.cluster-id: <cluster-id>
high-availability: kubernetes
high-availability.storageDir: hdfs:///flink/recovery {code}
and i found flink kubernetes operator 1.2.0 validate the kubernetes HA in the
old options:
{code:yaml}
high-availability:
org.apache.flink.kubernetes.highavailability.KubernetesHaServicesFactory {code}
it may be in the
org.apache.flink.kubernetes.operator.utils.FlinkUtils#isKubernetesHAActivated
to judge.
!image-2022-11-27-16-48-08-445.png!
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
