如何在 Samza worker 上获取应用程序 ID?
How get Application Id on Samza worker?
我不需要 "container id" 或 "App Attempt Id"。
在 documentation 上,我看到我们可以为 log4j 配置放置 ${samza.log.dir}
,此路径包含应用程序 ID。就像 /foo/log/../application_id_123
我找到了解决方法,如果你知道更好的解决方法可以回复。
final String samzaLogDir = System.getProperty("samza.log.dir");
final String[] samzaLogDirSplit = samzaLogDir.split("/");
final String applicationId = samzaLogDirSplit[samzaLogDirSplit.length - 2];
我不需要 "container id" 或 "App Attempt Id"。
在 documentation 上,我看到我们可以为 log4j 配置放置 ${samza.log.dir}
,此路径包含应用程序 ID。就像 /foo/log/../application_id_123
我找到了解决方法,如果你知道更好的解决方法可以回复。
final String samzaLogDir = System.getProperty("samza.log.dir");
final String[] samzaLogDirSplit = samzaLogDir.split("/");
final String applicationId = samzaLogDirSplit[samzaLogDirSplit.length - 2];