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/07/07 23:13:50 UTC

[1/2] incubator-beam git commit: remove an obsolete comment in KafkaIOTest.java

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 <ra...@apache.org>
Authored: Thu Jul 7 14:22:41 2016 -0700
Committer: GitHub <no...@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(),

[2/2] incubator-beam git commit: Closes #606

Posted by dh...@apache.org.
Closes #606


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

Branch: refs/heads/master
Commit: 155409bf6041380c309e4452719763a683d41936
Parents: 1963bde 1c9d16d
Author: Dan Halperin <dh...@google.com>
Authored: Thu Jul 7 16:13:36 2016 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Thu Jul 7 16:13:36 2016 -0700

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