You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2016/04/20 02:41:05 UTC
kafka git commit: MINOR: Fix typos in code comments
Repository: kafka
Updated Branches:
refs/heads/trunk 501fa3722 -> 0bf61039c
MINOR: Fix typos in code comments
This patch fixes all occurances of two consecutive 'the's in the code comments.
Author: Ishita Mandhan (imandhaus.ibm.com)
Author: Ishita Mandhan <im...@us.ibm.com>
Reviewers: Guozhang Wang <wa...@gmail.com>
Closes #1240 from imandhan/typofixes
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/0bf61039
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/0bf61039
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/0bf61039
Branch: refs/heads/trunk
Commit: 0bf61039c858af17260878d4815dbe7fb1645f90
Parents: 501fa37
Author: Ishita Mandhan <im...@us.ibm.com>
Authored: Tue Apr 19 17:39:04 2016 -0700
Committer: Guozhang Wang <wa...@gmail.com>
Committed: Tue Apr 19 17:39:04 2016 -0700
----------------------------------------------------------------------
.../apache/kafka/clients/producer/internals/RecordAccumulator.java | 2 +-
.../src/main/java/org/apache/kafka/common/network/LoginType.java | 2 +-
.../src/main/java/org/apache/kafka/common/protocol/Protocol.java | 2 +-
.../src/main/java/org/apache/kafka/connect/data/ConnectSchema.java | 2 +-
core/src/main/scala/kafka/admin/TopicCommand.scala | 2 +-
core/src/main/scala/kafka/utils/ZkUtils.scala | 2 +-
core/src/test/scala/unit/kafka/log/LogTest.scala | 2 +-
core/src/test/scala/unit/kafka/server/ClientQuotaManagerTest.scala | 2 +-
docs/streams.html | 2 +-
9 files changed, 9 insertions(+), 9 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/0bf61039/clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java
----------------------------------------------------------------------
diff --git a/clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java b/clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java
index 7f5b16f..d963981 100644
--- a/clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java
+++ b/clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java
@@ -467,7 +467,7 @@ public final class RecordAccumulator {
abortBatches();
} while (appendsInProgress());
// After this point, no thread will append any messages because they will see the close
- // flag set. We need to do the last abort after no thread was appending in case the there was a new
+ // flag set. We need to do the last abort after no thread was appending in case there was a new
// batch appended by the last appending thread.
abortBatches();
this.batches.clear();
http://git-wip-us.apache.org/repos/asf/kafka/blob/0bf61039/clients/src/main/java/org/apache/kafka/common/network/LoginType.java
----------------------------------------------------------------------
diff --git a/clients/src/main/java/org/apache/kafka/common/network/LoginType.java b/clients/src/main/java/org/apache/kafka/common/network/LoginType.java
index 9216cb0..a3a2b27 100644
--- a/clients/src/main/java/org/apache/kafka/common/network/LoginType.java
+++ b/clients/src/main/java/org/apache/kafka/common/network/LoginType.java
@@ -20,7 +20,7 @@ import org.apache.kafka.common.security.JaasUtils;
/**
* The type of the login context, it should be SERVER for the broker and CLIENT for the clients (i.e. consumer and
- * producer). It provides the the login context name which defines the section of the JAAS configuration file to be used
+ * producer). It provides the login context name which defines the section of the JAAS configuration file to be used
* for login.
*/
public enum LoginType {
http://git-wip-us.apache.org/repos/asf/kafka/blob/0bf61039/clients/src/main/java/org/apache/kafka/common/protocol/Protocol.java
----------------------------------------------------------------------
diff --git a/clients/src/main/java/org/apache/kafka/common/protocol/Protocol.java b/clients/src/main/java/org/apache/kafka/common/protocol/Protocol.java
index 475a4f2..248b7ec 100644
--- a/clients/src/main/java/org/apache/kafka/common/protocol/Protocol.java
+++ b/clients/src/main/java/org/apache/kafka/common/protocol/Protocol.java
@@ -478,7 +478,7 @@ public class Protocol {
"The current state of the group (one of: Dead, Stable, AwaitingSync, or PreparingRebalance, or empty if there is no active group)"),
new Field("protocol_type",
STRING,
- "The current group protocol type (will be empty if the there is no active group)"),
+ "The current group protocol type (will be empty if there is no active group)"),
new Field("protocol",
STRING,
"The current group protocol (only provided if the group is Stable)"),
http://git-wip-us.apache.org/repos/asf/kafka/blob/0bf61039/connect/api/src/main/java/org/apache/kafka/connect/data/ConnectSchema.java
----------------------------------------------------------------------
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/data/ConnectSchema.java b/connect/api/src/main/java/org/apache/kafka/connect/data/ConnectSchema.java
index 37c056a..591644c 100644
--- a/connect/api/src/main/java/org/apache/kafka/connect/data/ConnectSchema.java
+++ b/connect/api/src/main/java/org/apache/kafka/connect/data/ConnectSchema.java
@@ -299,7 +299,7 @@ public class ConnectSchema implements Schema {
/**
- * Get the {@link Schema.Type} associated with the the given class.
+ * Get the {@link Schema.Type} associated with the given class.
*
* @param klass the Class to
* @return the corresponding type, nor null if there is no matching type
http://git-wip-us.apache.org/repos/asf/kafka/blob/0bf61039/core/src/main/scala/kafka/admin/TopicCommand.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/admin/TopicCommand.scala b/core/src/main/scala/kafka/admin/TopicCommand.scala
index dd4ea88..232db4a 100755
--- a/core/src/main/scala/kafka/admin/TopicCommand.scala
+++ b/core/src/main/scala/kafka/admin/TopicCommand.scala
@@ -379,7 +379,7 @@ object TopicCommand extends Logging {
def shortMessageSizeWarning(maxMessageBytes: Int): String = {
"\n\n" +
"*****************************************************************************************************\n" +
- "*** WARNING: you are creating a topic where the the max.message.bytes is greater than the consumer ***\n" +
+ "*** WARNING: you are creating a topic where the max.message.bytes is greater than the consumer ***\n" +
"*** default. This operation is potentially dangerous. Consumers will get failures if their ***\n" +
"*** fetch.message.max.bytes < the value you are using. ***\n" +
"*****************************************************************************************************\n" +
http://git-wip-us.apache.org/repos/asf/kafka/blob/0bf61039/core/src/main/scala/kafka/utils/ZkUtils.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/utils/ZkUtils.scala b/core/src/main/scala/kafka/utils/ZkUtils.scala
index bd8ec7e..155b3fd 100644
--- a/core/src/main/scala/kafka/utils/ZkUtils.scala
+++ b/core/src/main/scala/kafka/utils/ZkUtils.scala
@@ -668,7 +668,7 @@ class ZkUtils(val zkClient: ZkClient,
}
}
- // Parses without deduplicating keys so the the data can be checked before allowing reassignment to proceed
+ // Parses without deduplicating keys so the data can be checked before allowing reassignment to proceed
def parsePartitionReassignmentDataWithoutDedup(jsonData: String): Seq[(TopicAndPartition, Seq[Int])] = {
Json.parseFull(jsonData) match {
case Some(m) =>
http://git-wip-us.apache.org/repos/asf/kafka/blob/0bf61039/core/src/test/scala/unit/kafka/log/LogTest.scala
----------------------------------------------------------------------
diff --git a/core/src/test/scala/unit/kafka/log/LogTest.scala b/core/src/test/scala/unit/kafka/log/LogTest.scala
index 3f6a275..8c973a4 100755
--- a/core/src/test/scala/unit/kafka/log/LogTest.scala
+++ b/core/src/test/scala/unit/kafka/log/LogTest.scala
@@ -228,7 +228,7 @@ class LogTest extends JUnitSuite {
/**
* Test reading at the boundary of the log, specifically
* - reading from the logEndOffset should give an empty message set
- * - reading from the the maxOffset should give an empty message set
+ * - reading from the maxOffset should give an empty message set
* - reading beyond the log end offset should throw an OffsetOutOfRangeException
*/
@Test
http://git-wip-us.apache.org/repos/asf/kafka/blob/0bf61039/core/src/test/scala/unit/kafka/server/ClientQuotaManagerTest.scala
----------------------------------------------------------------------
diff --git a/core/src/test/scala/unit/kafka/server/ClientQuotaManagerTest.scala b/core/src/test/scala/unit/kafka/server/ClientQuotaManagerTest.scala
index 193acfd..69e83c0 100644
--- a/core/src/test/scala/unit/kafka/server/ClientQuotaManagerTest.scala
+++ b/core/src/test/scala/unit/kafka/server/ClientQuotaManagerTest.scala
@@ -104,7 +104,7 @@ class ClientQuotaManagerTest {
assertEquals(10, numCallbacks)
time.sleep(sleepTime)
- // Callback can only be triggered after the the delay time passes
+ // Callback can only be triggered after the delay time passes
clientMetrics.throttledRequestReaper.doWork()
assertEquals(0, queueSizeMetric.value().toInt)
assertEquals(11, numCallbacks)
http://git-wip-us.apache.org/repos/asf/kafka/blob/0bf61039/docs/streams.html
----------------------------------------------------------------------
diff --git a/docs/streams.html b/docs/streams.html
index 9b94bb3..91fda36 100644
--- a/docs/streams.html
+++ b/docs/streams.html
@@ -64,7 +64,7 @@ developers define and connect custom processors as well as to interact with <a h
<h5><a id="streams_time" href="#streams_time">Time</a></h5>
<p>
-A critical aspect in stream processing is the the notion of <b>time</b>, and how it is modeled and integrated.
+A critical aspect in stream processing is the notion of <b>time</b>, and how it is modeled and integrated.
For example, some operations such as <b>windowing</b> are defined based on time boundaries.
</p>
<p>