melin created FLINK-30123: ----------------------------- Summary: Optimize ApplicationDeployer API design Key: FLINK-30123 URL: https://issues.apache.org/jira/browse/FLINK-30123 Project: Flink Issue Type: New Feature Reporter: melin Attachments: image-2022-11-22-09-28-38-631.png, image-2022-11-22-09-28-54-660.png
采用 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! -- This message was sent by Atlassian Jira (v8.20.10#820010)