[
https://issues.apache.org/jira/browse/FLINK-30222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-30222.
----------------------------------
Resolution: Fixed
[{{458022d}}|https://github.com/apache/flink-kubernetes-operator/commit/458022d2e67247c9941f102fb39d9dda96bd8837]
in main
> 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: 1.16.0, kubernetes-operator-1.2.0
> Reporter: tanjialiang
> Assignee: Peter Vary
> Priority: Blocker
> Labels: pull-request-available
> Fix For: kubernetes-operator-1.3.0
>
> 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)
