[
https://issues.apache.org/jira/browse/FLINK-23849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17403870#comment-17403870
]
Till Rohrmann commented on FLINK-23849:
---------------------------------------
I agree that this feature is very useful.
Yes, if you want to have exactly-once processing guarantees then you need to
use a transaction sink or a sink that uses idempotent write operations. But
this is true in any case because a node failure can happen at any time, not
only if you decommission a machine.
> 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)
