You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by dh...@apache.org on 2016/08/30 00:19:58 UTC
[1/2] incubator-beam git commit: Closes #900
Repository: incubator-beam
Updated Branches:
refs/heads/master 6d4c739c0 -> c94822637
Closes #900
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c9482263
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c9482263
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/c9482263
Branch: refs/heads/master
Commit: c9482263747caee08c98a25190bb46a9b16dd371
Parents: 6d4c739 20b5fe4
Author: Dan Halperin <dh...@google.com>
Authored: Mon Aug 29 17:19:52 2016 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Mon Aug 29 17:19:52 2016 -0700
----------------------------------------------------------------------
.../kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
[2/2] incubator-beam git commit: Returned KafkaIO getWatermark log
line in debug mode
Posted by dh...@apache.org.
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/20b5fe41
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/20b5fe41
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/20b5fe41
Branch: refs/heads/master
Commit: 20b5fe41c314d4fa16c4c16d2287bc5019642f4a
Parents: 6d4c739
Author: Aviem Zur <av...@gmail.com>
Authored: Sun Aug 28 11:41:58 2016 +0300
Committer: Dan Halperin <dh...@google.com>
Committed: Mon Aug 29 17:19:52 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/20b5fe41/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;
}