You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by zs...@apache.org on 2016/01/11 20:29:19 UTC
spark git commit: [STREAMING][MINOR] Typo fixes
Repository: spark
Updated Branches:
refs/heads/master 9559ac5f7 -> b313badaa
[STREAMING][MINOR] Typo fixes
Author: Jacek Laskowski <ja...@japila.pl>
Closes #10698 from jaceklaskowski/streaming-kafka-typo-fixes.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/b313bada
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/b313bada
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/b313bada
Branch: refs/heads/master
Commit: b313badaa049f847f33663c61cd70ee2f2cbebac
Parents: 9559ac5
Author: Jacek Laskowski <ja...@japila.pl>
Authored: Mon Jan 11 11:29:15 2016 -0800
Committer: Shixiong Zhu <sh...@databricks.com>
Committed: Mon Jan 11 11:29:15 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/b313bada/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 c4e18d9..d7885d7 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
@@ -385,7 +385,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/b313bada/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 603be22..4eb1556 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