You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "zlzhang0122 (Jira)" <ji...@apache.org> on 2021/08/18 04:05:00 UTC

[jira] [Created] (FLINK-23849) Support react to the node decommissioning change state on yarn and do graceful restart

zlzhang0122 created FLINK-23849:
-----------------------------------

             Summary: 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: Improvement
          Components: Deployment / YARN
    Affects Versions: 1.13.2, 1.13.1, 1.12.2
            Reporter: zlzhang0122
             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 the 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 and then restart it.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)