Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-23849

Support react to the node decommissioning change state on yarn and do graceful restart

    XMLWordPrintableJSON

Details

    • New Feature
    • Status: Open
    • Major
    • Resolution: Unresolved
    • None
    • 1.20.0
    • Deployment / YARN
    • None

    Description

      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.

      Attachments

        Activity

          People

            Unassigned Unassigned
            zlzhang0122 zlzhang0122
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated: