Returned KafkaIO getWatermark log line in debug mode
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a58afd3d Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a58afd3d Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/a58afd3d Branch: refs/heads/gearpump-runner Commit: a58afd3db8cdce4f5135b78f3785c8b3ff7fb0ab Parents: cf9ce2f Author: Aviem Zur <aviem...@gmail.com> Authored: Sun Aug 28 11:41:58 2016 +0300 Committer: Dan Halperin <dhalp...@google.com> Committed: Mon Sep 12 17:40:11 2016 -0700 ---------------------------------------------------------------------- .../kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/a58afd3d/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java b/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java index f639422..f16a5ab 100644 --- a/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java +++ b/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java @@ -1072,6 +1072,7 @@ public class KafkaIO { @Override public Instant getWatermark() { if (curRecord == null) { + LOG.debug("{}: getWatermark() : no records have been read yet.", name); return initialWatermark; }
