You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ro...@apache.org on 2020/08/12 16:38:43 UTC
[beam] branch master updated: Fix some typos (#12539)
This is an automated email from the ASF dual-hosted git repository.
robinyqiu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 5f10b99 Fix some typos (#12539)
5f10b99 is described below
commit 5f10b99458ac8b2850e310cd6938e25c076b31f4
Author: Yueyang Qiu <ro...@gmail.com>
AuthorDate: Wed Aug 12 09:38:12 2020 -0700
Fix some typos (#12539)
---
.../io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 4 ++--
.../src/main/java/org/apache/beam/sdk/io/kafka/KafkaIOUtils.java | 2 +-
.../src/main/java/org/apache/beam/sdk/tpcds/SqlTransformRunner.java | 3 ++-
3 files changed, 5 insertions(+), 4 deletions(-)
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 4190e26..b14ef22 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
@@ -1388,8 +1388,8 @@ public class KafkaIO {
/**
* Updates configuration for the main consumer. This method merges updates from the provided map
- * with with any prior updates using {@link KafkaIOUtils#DEFAULT_CONSUMER_PROPERTIES} as the
- * starting configuration.
+ * with any prior updates using {@link KafkaIOUtils#DEFAULT_CONSUMER_PROPERTIES} as the starting
+ * configuration.
*
* <p>In {@link ReadFromKafkaDoFn}, there're two consumers running in the backend:
*
diff --git a/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIOUtils.java b/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIOUtils.java
index 0589a05..c8acb9f 100644
--- a/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIOUtils.java
+++ b/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIOUtils.java
@@ -43,7 +43,7 @@ final class KafkaIOUtils {
ByteArrayDeserializer.class.getName(),
// Use large receive buffer. Once KAFKA-3135 is fixed, this _may_ not be required.
- // with default value of of 32K, It takes multiple seconds between successful polls.
+ // with default value of 32K, It takes multiple seconds between successful polls.
// All the consumer work is done inside poll(), with smaller send buffer size, it
// takes many polls before a 1MB chunk from the server is fully read. In my testing
// about half of the time select() inside kafka consumer waited for 20-30ms, though
diff --git a/sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/SqlTransformRunner.java b/sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/SqlTransformRunner.java
index 749bfbd..2614ce2 100644
--- a/sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/SqlTransformRunner.java
+++ b/sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/SqlTransformRunner.java
@@ -83,7 +83,8 @@ public class SqlTransformRunner {
}
/**
- * This is the default method in BeamTpcds.main method. Run job using SqlTranform.query() method.
+ * This is the default method in BeamTpcds.main method. Run job using SqlTransform.query()
+ * method.
* @param args Command line arguments
* @throws Exception
*/