[
https://issues.apache.org/jira/browse/FLINK-23849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402131#comment-17402131
]
Till Rohrmann commented on FLINK-23849:
---------------------------------------
Thanks for reporting this issue [~zlzhang0122]. I think what you are interested
in is actually a non-trivial new feature. At the moment Flink does not support
it but Flink will recover if you kill a machine on which a {{TaskExecutor}}
with some {{Tasks}} is running. Just to manage expectations, I am not sure how
fast the Flink community will be able to implement your requested feature.
> Support react to the node decommissioning change state on yarn and do
> graceful restart
> --------------------------------------------------------------------------------------
>
> Key: FLINK-23849
> URL: https://issues.apache.org/jira/browse/FLINK-23849
> Project: Flink
> Issue Type: New Feature
> Components: Deployment / YARN
> Affects Versions: 1.12.2, 1.13.1, 1.13.2
> Reporter: zlzhang0122
> Priority: Major
> Fix For: 1.15.0
>
>
> Now we are not interested in node updates in
> YarnContainerEventHandler.onNodesUpdated , but sometimes we want to evict the
> running flink process on one node and graceful restart on the other node
> because of some unexpected reason such as the physical machine need to be
> recycle or the cloud computing cluster need to be migration. Thus, we can
> react to the node decommissioning change state, and call the
> stopWithSavepoint function and then restart it.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
