如何从 Apache Apex 应用程序内部获取 ApplicationID？

Posted 2023-04-18

【中文标题】如何从 Apache Apex 应用程序内部获取 ApplicationID？

【英文标题】：How to get ApplicationID from inside Apache Apex application?

【发布时间】：2016-05-21 03:17:17

【问题描述】：

是否可以在 Apex 程序中检索 Apex 应用程序 ID：例如 application_1463594017097_0024？例如来自 DAG 对象或其他对象？

【参考方案1】：

使用传递给StreamingApplication的conf对象

String appid = dag.getValue(DAGContext.APPLICATION_ID);

在运算符中，使用

字符串 appid = Context.OperatorContext.getValue(Context.DAGContext. APPLICATION_ID);

注意： 它不能在 populateDAG 函数中运行。 APPLICATION_ID 在应用程序启动后分配给它。在 populateDag() 阶段，正在创建逻辑计划，但未创建实际的 YARN 应用程序。尚未创建 APPLICATION_ID，这就是它为空的原因。