spark-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From zsxw...@apache.org
Subject spark git commit: [STREAMING][MINOR] Typo fixes
Date Mon, 11 Jan 2016 19:29:26 GMT
Repository: spark
Updated Branches:
  refs/heads/branch-1.6 d4cfd2acd -> ce906b33d


[STREAMING][MINOR] Typo fixes

Author: Jacek Laskowski <jacek@japila.pl>

Closes #10698 from jaceklaskowski/streaming-kafka-typo-fixes.

(cherry picked from commit b313badaa049f847f33663c61cd70ee2f2cbebac)
Signed-off-by: Shixiong Zhu <shixiong@databricks.com>


Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/ce906b33
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/ce906b33
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/ce906b33

Branch: refs/heads/branch-1.6
Commit: ce906b33de64f55653b52376316aa2625fd86b47
Parents: d4cfd2a
Author: Jacek Laskowski <jacek@japila.pl>
Authored: Mon Jan 11 11:29:15 2016 -0800
Committer: Shixiong Zhu <shixiong@databricks.com>
Committed: Mon Jan 11 11:29:23 2016 -0800

----------------------------------------------------------------------
 .../main/scala/org/apache/spark/streaming/kafka/KafkaCluster.scala | 2 +-
 .../src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/spark/blob/ce906b33/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaCluster.scala
----------------------------------------------------------------------
diff --git a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaCluster.scala
b/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaCluster.scala
index 8465432..e3a2e57 100644
--- a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaCluster.scala
+++ b/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaCluster.scala
@@ -382,7 +382,7 @@ object KafkaCluster {
     val seedBrokers: Array[(String, Int)] = brokers.split(",").map { hp =>
       val hpa = hp.split(":")
       if (hpa.size == 1) {
-        throw new SparkException(s"Broker not the in correct format of <host>:<port>
[$brokers]")
+        throw new SparkException(s"Broker not in the correct format of <host>:<port>
[$brokers]")
       }
       (hpa(0), hpa(1).toInt)
     }

http://git-wip-us.apache.org/repos/asf/spark/blob/ce906b33/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala
----------------------------------------------------------------------
diff --git a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala
b/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala
index ea5f842..4dbaf4f 100644
--- a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala
+++ b/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala
@@ -156,7 +156,7 @@ class KafkaRDD[
     var requestOffset = part.fromOffset
     var iter: Iterator[MessageAndOffset] = null
 
-    // The idea is to use the provided preferred host, except on task retry atttempts,
+    // The idea is to use the provided preferred host, except on task retry attempts,
     // to minimize number of kafka metadata requests
     private def connectLeader: SimpleConsumer = {
       if (context.attemptNumber > 0) {


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org


Mime
View raw message