[
https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807612#comment-17807612
]
Matthias Pohl commented on FLINK-34007:
---------------------------------------
good point, a the holder identity would have to be reset as well.
I'm also wondering whether we should enable
[isReleaseOnCancel()|https://github.com/fabric8io/kubernetes-client/blob/0f6c696509935a6a86fdb4620caea023d8e680f1/kubernetes-client-api/src/main/java/io/fabric8/kubernetes/client/extended/leaderelection/LeaderElector.java#L124].
That config property was never used in the kubernetes-client v5.12.4 codebase
and seems to be disabled by default. We're not enabling it in
[KubernetesLeaderElector:69|https://github.com/apache/flink/blob/c5808b04fdce9ca0b705b6cc7a64666ab6426875/flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/resources/KubernetesLeaderElector.java#L69]
on the Flink side. Releasing the lock identify might help in certain situation
where we don't want to wait for the lease to timeout. But that's just a minor
improvement that I came across while looking through the v6.6.2 code.
[~ZhenqiuHuang] But that finding still doesn't explain that you're seeing the
same/similar issues with Flink 1.17- deployments. Because the update of the
kubernetes-client to v6.6.2 only happened in 1.18.0.
> Flink Job stuck in suspend state after losing leadership in HA Mode
> -------------------------------------------------------------------
>
> Key: FLINK-34007
> URL: https://issues.apache.org/jira/browse/FLINK-34007
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Coordination
> Affects Versions: 1.16.3, 1.17.2, 1.18.1, 1.18.2
> Reporter: Zhenqiu Huang
> Priority: Major
> Attachments: Debug.log, LeaderElector-Debug.json, job-manager.log
>
>
> The observation is that Job manager goes to suspend state with a failed
> container not able to register itself to resource manager after timeout.
> JM Log, see attached
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
