我使用 yarn-session
命令在机器A上启动了纱线 - 会议应用程序(在纱线上运行的长期运行应用程序(,我想使用机器B上的Flink Run -YID提交Flink应用程序。
那么,如何自动拾取运行从机器A开始的纱线会话的应用程序ID?特别是,纱线会议可能会从期间重新启动(例如,由于某些原因,必须重新启动弗林克课程,例如机器下降等(
您可以使用./yarn-session.sh -nm ${your-app-name}
命名纱线应用程序。然后,您可以通过此名称找到纱线应用ID。一种可能的解决方案是:
applicationId=$(yarn application -list | awk '{if ($2==${your-app-name}) print $1 }')