beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dhalp...@apache.org
Subject [17/50] [abbrv] incubator-beam git commit: Returned KafkaIO getWatermark log line in debug mode
Date Tue, 13 Sep 2016 00:40:48 GMT
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 <aviemzur@gmail.com>
Authored: Sun Aug 28 11:41:58 2016 +0300
Committer: Dan Halperin <dhalperi@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;
       }
 


Mime
View raw message