review comment

andrewor14 · Mar 5, 2014 · b0d5c07 · b0d5c07
1 parent d0a6005
commit b0d5c07
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/core/src/main/scala/org/apache/spark/SparkContext.scala b/core/src/main/scala/org/apache/spark/SparkContext.scala
@@ -848,7 +848,7 @@ class SparkContext(
       allowLocal: Boolean,
       resultHandler: (Int, U) => Unit) {
     val outIndex = partitions.toSet.diff(rdd.partitions.map(_.index).toSet)
-    require(outIndex.isEmpty,"Partition index out of bounds: "+ outIndex.mkString(","))
+    require(outIndex.isEmpty,"Partition index out of bounds: " + outIndex.mkString(","))
     val callSite = getCallSite
     val cleanedFunc = clean(func)
     logInfo("Starting job: " + callSite)
@@ -953,7 +953,7 @@ class SparkContext(
       resultFunc: => R): SimpleFutureAction[R] =
   {
     val outIndex = partitions.toSet.diff(rdd.partitions.map(_.index).toSet)
-    require(outIndex.isEmpty,"Partition index out of bounds: "+ outIndex.mkString(","))
+    require(outIndex.isEmpty,"Partition index out of bounds: " + outIndex.mkString(","))
     val cleanF = clean(processPartition)
     val callSite = getCallSite
     val waiter = dagScheduler.submitJob(