• 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏吧

标签:apache-samza

apache-samza

samza容器出现故障

samza容器出现故障
您好,我的samza作业容器由于以下错误而经常失败: Exception from container-launch. Container id: container_1540535314451_0141_01_000021 Exit code: 1 Stack trace: ExitCodeException exitCode=1: at org.apa……继续阅读 »

apache-beam

与Beam中的跑步者依赖项冲突

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

apache-kafka

如何在Samza worker上获得应用程序ID?

如何在Samza worker上获得应用程序ID?
我不需要“容器ID”或“应用尝试ID”。 在documentation上,我看到我们可以将${samza.log.dir}放在log4j配置中,并且该路径包含应用程序ID。就像/foo/log/../application_id_123 解决方案如下: 我找到了解决方案,如果您知道更好的解决方案,则可以答复。 final String samzaL……继续阅读 »