You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by re...@apache.org on 2017/10/17 15:17:47 UTC
[12/13] beam git commit: update JavaDoc for withEOS().
update JavaDoc for withEOS().
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/686b22f3
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/686b22f3
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/686b22f3
Branch: refs/heads/master
Commit: 686b22f36e9ad487d99a184c9d9c6218b7f938d4
Parents: 0d5a3e2
Author: Raghu Angadi <ra...@google.com>
Authored: Thu Oct 5 18:28:52 2017 -0700
Committer: Raghu Angadi <ra...@google.com>
Committed: Tue Oct 17 00:03:17 2017 -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/beam/blob/686b22f3/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 5291606..603e62f 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
@@ -1614,7 +1614,6 @@ public class KafkaIO {
if (isEOS()) {
EOSWrite.ensureEOSSupport();
- checkNotNull(getSinkGroupId(), "A group id is required for exactly-once sink");
// TODO: Verify that the group_id does not have existing state stored on Kafka unless
// this is an upgrade. This avoids issues with simple mistake of reusing group_id