通过 命令 操作flink on yarn 如何优雅的停止flink任务

通过命令操作Flink on Yarn停止任务有多种方式，具体取决于你使用的是哪种模式。在application模式下，可以使用以下命令停止任务：

./bin/flink cancel -t yarn-application -Dyarn.application.id=application_XXXX_YY <jobId>

其中，`application_XXXX_YY`是Yarn应用程序的ID，`<jobId>`是Flink任务的ID。这个命令将取消指定的任务，并停止整个集群。

在per-job模式下，可以使用以下命令停止任务：

./bin/flink cancel -t yarn-per-job -Dyarn.application.id=application_XXXX_YY <jobId>

同样，`application_XXXX_YY`是Yarn应用程序的ID，`<jobId>`是Flink任务的ID。这个命令将取消指定的任务。

如果你使用的是session模式，可以使用以下命令停止任务：

./bin/flink cancel -t yarn-session -Dyarn.application.id=application_XXXX_YY <jobId>

同样，`application_XXXX_YY`是Yarn应用程序的ID，`<jobId>`是Flink任务的ID。这个命令将取消指定的任务。

总结起来，通过命令操作Flink on Yarn停止任务的方式取决于你使用的是application模式、per-job模式还是session模式。你可以根据具体的模式选择相应的命令来停止任务。
#### 引用[.reference_title]
- *1* [【FLink】Flink 任务 如何优雅的停止](https://blog.csdn.net/qq_21383435/article/details/124719051)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v91^control,239^v3^insert_chatgpt"}} ] [.reference_item]
- *2* *3* [Flink On Yarn提交方式](https://blog.csdn.net/u012667450/article/details/124459760)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v91^control,239^v3^insert_chatgpt"}} ] [.reference_item]
[ .reference_list ]