beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dhalp...@apache.org
Subject [1/2] incubator-beam git commit: remove an obsolete comment in KafkaIOTest.java
Date Thu, 07 Jul 2016 23:13:50 GMT
Repository: incubator-beam
Updated Branches:
  refs/heads/master 1963bde44 -> 155409bf6


remove an obsolete comment in KafkaIOTest.java

Kafka 10.0 added compatible constructor for ConsumerRecord. It was not present when I wrote
this test. https://github.com/apache/kafka/commit/4e557f8ef60d46a8870704655c9a35092f74d125

Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1c9d16d7
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/1c9d16d7
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/1c9d16d7

Branch: refs/heads/master
Commit: 1c9d16d70ad2bd55b0736ea37f9357029f39ade5
Parents: 1963bde
Author: Raghu Angadi <rangadi@apache.org>
Authored: Thu Jul 7 14:22:41 2016 -0700
Committer: GitHub <noreply@github.com>
Committed: Thu Jul 7 14:22:41 2016 -0700

----------------------------------------------------------------------
 .../src/test/java/org/apache/beam/sdk/io/kafka/KafkaIOTest.java     | 1 -
 1 file changed, 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/1c9d16d7/sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaIOTest.java
----------------------------------------------------------------------
diff --git a/sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaIOTest.java
b/sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaIOTest.java
index 587e3e2..dd93823 100644
--- a/sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaIOTest.java
+++ b/sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaIOTest.java
@@ -126,7 +126,6 @@ public class KafkaIOTest {
         records.put(tp, new ArrayList<ConsumerRecord<byte[], byte[]>>());
       }
       records.get(tp).add(
-          // Note: this interface has changed in 0.10. may get fixed before the release.
           new ConsumerRecord<byte[], byte[]>(
               tp.topic(),
               tp.partition(),


Mime
View raw message