samza 作业中的 MetricsSnapshotReporterFactory 警告

MetricsSnapshotReporterFactory warning in samza job

我在 samza 作业中收到以下警告:

[main] WARN o.a.s.m.r.MetricsSnapshotReporterFactory.warn(66) - Unable to find implementation version in jar's meta info. Defaulting to 0.0.1.

我该如何解决?我错过了什么?

这似乎是一个良性警告。这意味着您的 StreamTask 实现("task.class" 指向的 class)没有在 jar 中列出版本。 你可以忽略它。 如果您想在 jar 中包含版本控制信息,您可以根据指南 here 添加 Manifest.txt 到您的 jar。这应该摆脱警告。 我可以想到一个场景,您想要区分从一个版本的 Samza 作业发布的指标到另一个版本。在这种情况下,将版本控制信息添加到清单文件会有所帮助。 HTH!