[
https://issues.apache.org/jira/browse/FLINK-30123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
melin updated FLINK-30123:
--------------------------
Description:
The task is submitted by ApplicationDeployer api, and the run is synchronous
and waiting for the submission to be completed. If the task is submitted to
yarn, it is probably accepted and the yarn applicationID is not obtained at
this time. It is difficult to cancel the task.Recommended to org. apache.
spark.launcher.SparkLauncher design, asynchronous submission tasks, can obtain
applicationId as soon as possible, if you want to delete the task ahead of
time, direct yarn application - kill XXX;
!image-2022-11-22-09-28-38-631.png!
!image-2022-11-22-09-28-54-660.png!
was:
采用 ApplicationDeployer api 提交任务，run是同步等待提交完成，如果任务提交yarn，可能一直都是accepted
状态，这个时候没有获取yarn applicationID，如果想取消任务是比较难的，建议参考
org.apache.spark.launcher.SparkLauncher
设计，异步提交任务，能够尽快获取applicationId，如果想提前删掉任务，直接yarn application -kill xxx;
!image-2022-11-22-09-28-38-631.png!
!image-2022-11-22-09-28-54-660.png!
> Optimize ApplicationDeployer API design
> ---------------------------------------
>
> Key: FLINK-30123
> URL: https://issues.apache.org/jira/browse/FLINK-30123
> Project: Flink
> Issue Type: New Feature
> Reporter: melin
> Priority: Major
> Attachments: image-2022-11-22-09-28-38-631.png,
> image-2022-11-22-09-28-54-660.png
>
>
> The task is submitted by ApplicationDeployer api, and the run is synchronous
> and waiting for the submission to be completed. If the task is submitted to
> yarn, it is probably accepted and the yarn applicationID is not obtained at
> this time. It is difficult to cancel the task.Recommended to org. apache.
> spark.launcher.SparkLauncher design, asynchronous submission tasks, can
> obtain applicationId as soon as possible, if you want to delete the task
> ahead of time, direct yarn application - kill XXX;
> !image-2022-11-22-09-28-38-631.png!
> !image-2022-11-22-09-28-54-660.png!
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
