我正在运行oozie工作流，并在map reduce操作中进行map-only分布式模型拟合。由于有许多Map程序，我编写了一个代码，使用 yarn logs -applicationId application_x 其中application_x是所有map任务的父应用程序id。现在我想把这个摘要作为工作流程的一部分，所以我需要 application_x 它是上一个操作的应用程序id。有什么办法让我得到这个吗？
yarn logs -applicationId application_x
application_x
bejyjqdl1#
我还没有测试过这个，但是我认为你可以通过工作流el函数得到这个：
wf:actionExternalId(String node) It returns the external Id for an action node, or an empty string if the action has not being executed or it has not completed yet.
因此，在map reduce作业完成后的节点中，应该能够使用likel
wf:actionExternalId('mapred-node-name')
我怀疑它将返回job\u 而不是application\u ，但您可能可以处理这个问题。
1条答案
按热度按时间bejyjqdl1#
我还没有测试过这个，但是我认为你可以通过工作流el函数得到这个：
因此，在map reduce作业完成后的节点中，应该能够使用likel
我怀疑它将返回job\u 而不是application\u ，但您可能可以处理这个问题。