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/23 16:59:58 UTC
[1/2] incubator-beam git commit: [BEAM-574] Remove log when new
records have not been read yet (KafkaIO)
Repository: incubator-beam
Updated Branches:
refs/heads/master a8b2d6cc9 -> b380a677b
[BEAM-574] Remove log when new records have not been read yet (KafkaIO)
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b1123417
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b1123417
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/b1123417
Branch: refs/heads/master
Commit: b1123417a6b55fba1560fa68096d0b5551efa960
Parents: a8b2d6c
Author: Isma�l Mej�a <ie...@gmail.com>
Authored: Mon Aug 22 17:25:32 2016 +0200
Committer: Dan Halperin <dh...@google.com>
Committed: Tue Aug 23 09:59:52 2016 -0700
----------------------------------------------------------------------
.../kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 1 -
1 file changed, 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b1123417/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 8a0c788..6cc5d6a 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
@@ -1076,7 +1076,6 @@ public class KafkaIO {
@Override
public Instant getWatermark() {
if (curRecord == null) {
- LOG.warn("{}: getWatermark() : no records have been read yet.", name);
return initialWatermark;
}
[2/2] incubator-beam git commit: Closes #859
Posted by dh...@apache.org.
Closes #859
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b380a677
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b380a677
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/b380a677
Branch: refs/heads/master
Commit: b380a677b2823897b1ecc1b903e0775d794423e0
Parents: a8b2d6c b112341
Author: Dan Halperin <dh...@google.com>
Authored: Tue Aug 23 09:59:53 2016 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Tue Aug 23 09:59:53 2016 -0700
----------------------------------------------------------------------
.../kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 1 -
1 file changed, 1 deletion(-)
----------------------------------------------------------------------