You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by sr...@apache.org on 2015/12/03 17:09:10 UTC
spark git commit: [DOCUMENTATION][KAFKA] fix typo in
kafka/OffsetRange.scala
Repository: spark
Updated Branches:
refs/heads/master 7470d9edb -> 95b3cf125
[DOCUMENTATION][KAFKA] fix typo in kafka/OffsetRange.scala
this is to fix some typo in external/kafka/src/main/scala/org/apache/spark/streaming/kafka/OffsetRange.scala
Author: microwishing <we...@kaiyuandao.com>
Closes #10121 from microwishing/master.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/95b3cf12
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/95b3cf12
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/95b3cf12
Branch: refs/heads/master
Commit: 95b3cf125b905b4ef8705c46f2ef255377b0a9dc
Parents: 7470d9e
Author: microwishing <we...@kaiyuandao.com>
Authored: Thu Dec 3 16:09:05 2015 +0000
Committer: Sean Owen <so...@cloudera.com>
Committed: Thu Dec 3 16:09:05 2015 +0000
----------------------------------------------------------------------
.../scala/org/apache/spark/streaming/kafka/KafkaTestUtils.scala | 2 +-
.../main/scala/org/apache/spark/streaming/kafka/OffsetRange.scala | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/95b3cf12/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaTestUtils.scala
----------------------------------------------------------------------
diff --git a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaTestUtils.scala b/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaTestUtils.scala
index 86394ea..45a6982 100644
--- a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaTestUtils.scala
+++ b/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaTestUtils.scala
@@ -151,7 +151,7 @@ private[kafka] class KafkaTestUtils extends Logging {
}
}
- /** Create a Kafka topic and wait until it propagated to the whole cluster */
+ /** Create a Kafka topic and wait until it is propagated to the whole cluster */
def createTopic(topic: String): Unit = {
AdminUtils.createTopic(zkClient, topic, 1, 1)
// wait until metadata is propagated
http://git-wip-us.apache.org/repos/asf/spark/blob/95b3cf12/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/OffsetRange.scala
----------------------------------------------------------------------
diff --git a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/OffsetRange.scala b/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/OffsetRange.scala
index 8a5f371..d9b856e 100644
--- a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/OffsetRange.scala
+++ b/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/OffsetRange.scala
@@ -20,7 +20,7 @@ package org.apache.spark.streaming.kafka
import kafka.common.TopicAndPartition
/**
- * Represents any object that has a collection of [[OffsetRange]]s. This can be used access the
+ * Represents any object that has a collection of [[OffsetRange]]s. This can be used to access the
* offset ranges in RDDs generated by the direct Kafka DStream (see
* [[KafkaUtils.createDirectStream()]]).
* {{{
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org