【发布时间】:2016-05-21 03:17:17
【问题描述】:
是否可以在 Apex 程序中检索 Apex 应用程序 ID:例如 application_1463594017097_0024?例如来自 DAG 对象或其他对象?
【问题讨论】:
标签: apache-apex
是否可以在 Apex 程序中检索 Apex 应用程序 ID:例如 application_1463594017097_0024?例如来自 DAG 对象或其他对象?
【问题讨论】:
标签: apache-apex
使用传递给StreamingApplication的conf对象
String appid = dag.getValue(DAGContext.APPLICATION_ID);
在运算符中,使用
字符串 appid = Context.OperatorContext.getValue(Context.DAGContext. APPLICATION_ID);
注意: 它不能在 populateDAG 函数中运行。 APPLICATION_ID 在应用程序启动后分配给它。在 populateDag() 阶段,正在创建逻辑计划,但未创建实际的 YARN 应用程序。尚未创建 APPLICATION_ID,这就是它为空的原因。
【讨论】: