Skip to content

Commit

Permalink
review comment
Browse files Browse the repository at this point in the history
  • Loading branch information
liguoqiang committed Mar 5, 2014
1 parent 3395ee7 commit d0a6005
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions core/src/main/scala/org/apache/spark/SparkContext.scala
Original file line number Diff line number Diff line change
Expand Up @@ -847,8 +847,8 @@ class SparkContext(
partitions: Seq[Int],
allowLocal: Boolean,
resultHandler: (Int, U) => Unit) {
require(partitions.toSet.diff(rdd.partitions.map(_.index).toSet).isEmpty,
"partition index out of range")
val outIndex = partitions.toSet.diff(rdd.partitions.map(_.index).toSet)
require(outIndex.isEmpty,"Partition index out of bounds: "+ outIndex.mkString(","))
val callSite = getCallSite
val cleanedFunc = clean(func)
logInfo("Starting job: " + callSite)
Expand Down Expand Up @@ -952,8 +952,8 @@ class SparkContext(
resultHandler: (Int, U) => Unit,
resultFunc: => R): SimpleFutureAction[R] =
{
require(partitions.toSet.diff(rdd.partitions.map(_.index).toSet).isEmpty,
"partition index out of range")
val outIndex = partitions.toSet.diff(rdd.partitions.map(_.index).toSet)
require(outIndex.isEmpty,"Partition index out of bounds: "+ outIndex.mkString(","))
val cleanF = clean(processPartition)
val callSite = getCallSite
val waiter = dagScheduler.submitJob(
Expand Down

0 comments on commit d0a6005

Please sign in to comment.