您好,我的samza作业容器由于以下错误而经常失败: Exception from container-launch. Container id: container_1540535314451_0141_01_000021 Exit code: 1 Stack trace: ExitCodeException exitCode=1: at org.apache.hadoop.util.Shell.runCommand(Shell.java:538) at org.apache.hadoop.util.Shell.…

2019年10月8日 0条评论 10点热度 阅读全文

我想使用Beam测试不同的流处理引擎,但是当包含Flink和Samza依赖项时无法运行该程序。如果只包括其中一个,则对其他所有跑步者都适用。 我的pom.xml包含以下内容: <properties> <maven.compiler.release>1.11</maven.compiler.release> <beam.version>2.20.0</beam.version> <flink.version>1.9</flink.vers…

2019年6月5日 0条评论 80点热度 阅读全文

我不需要“容器ID”或“应用尝试ID”。 在documentation上,我看到我们可以将${samza.log.dir}放在log4j配置中,并且该路径包含应用程序ID。就像/foo/log/../application_id_123 解决方案如下: 我找到了解决方案,如果您知道更好的解决方案,则可以答复。 final String samzaLogDir = System.getProperty("samza.log.dir"); final String[] samzaLogDirSplit = samzaL…

2019年2月4日 0条评论 14点热度 阅读全文