ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/master' into scala-2.9

Browse source
This commit is contained in:
Matei Zaharia 2011-06-27 22:50:59 -07:00
parent 85cad5d9dd b0ecf1ee41
commit 5633299ec6
1 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
core/src/main/scala/spark/DAGScheduler.scala
View file

@ -171,7 +171,8 @@ private trait DAGScheduler extends Scheduler with Logging {
if (finalStage.parents.size == 0 && numOutputParts == 1) {
logInfo("Computing the requested partition locally")
val split = finalRdd.splits(outputParts(0))
return Array(func(null, finalRdd.iterator(split)))
val taskContext = new TaskContext(finalStage.id, outputParts(0), 0)
return Array(func(taskContext, finalRdd.iterator(split)))
}
def submitStage(stage: Stage) {