如何使用应用程序id提交作业

blmhpbnm  于 2021-05-29  发布在  Hadoop
关注(0)|答案(1)|浏览(436)

我想知道yarn cli是否有可能使用前一次执行生成的application\ id重新提交yarn应用程序。
例子:

/opt/mapr/spark/spark-2.1.0/bin/spark-submit --num-executors 5 --executor-memory 2G --executor-cores 2  --master yarn --deploy-mode cluster --files /opt/mapr/hive/hive-2.1/conf/hive-site.xml --class com.cisco.sdp.cdx.processing.DenormScheduler JSONDenormJob-0.0.1-SNAPSHOT-jar-with-dependencies.jar

当我提交上述作业时,会创建一个应用程序id(例如:application\u 1522909218432\u 0485)。是否有方法使用命令行或JavaAPI中的应用程序id重新提交同一个作业。
就像 yarn application -submit <APPLICATION_ID> . 从帮助中我可以看出有一个选择 -movetoqueue <Application ID> . 我看不到任何重新提交的选择。只是想探索和理解为什么不提供重新提交工作的选项。

mepcadol

mepcadol1#

从api的Angular 来看,yarn不具备这种能力。应用程序id是作为createapplication调用的响应生成的,该调用不接收任何参数。

相关问题