1

在 Apache Crunch 中，有一个名为increment("any enum").

我使用increment(TOTAL_IDS);了，但是在我可以看到计数器结果的地方，计数器在完成工作后没有进入日志。

我在那里想念什么？

4

1 回答 1

1

您应该能够在 mapreduce 作业的跟踪 URL 中看到您的计数器（如果您正在运行 mapreduce）或从管道中提取计数器。如果您可以提供代码如何增加计数器，那将很有用？它在您的 DoFn 中，在您的 cleanp 方法中吗？

问候

于 2017-08-16T22:24:36.853 回答