FlinkFlink 自动重启过程

Posted 2023-03-07 九师兄

文章目录

• 1.概述
• 2. updateTaskExecutionState
• 3.处理异常
• • 3.1 获取要重启边的id
  • 3.2 处理异常handleFailure
• 4.可能要重启task-maybeRestartTasks
• • 4.1 restartTasksWithDelay
  • 4.2 重启task-restartTasks
  • 4.3 执行状态恢复
  • • 4.3.1 notifyCoordinatorsOfSubtaskRestore
  • 4.4 重启-restartTasks

1.概述

写这篇文章是因为我今天的一个任务原本好好的，