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 <[email protected]> Authored: Mon Aug 22 17:25:32 2016 +0200 Committer: Dan Halperin <[email protected]> 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; }
