diff options
| author | Aaron Davidson <aaron@databricks.com> | 2013-10-20 11:03:36 -0700 |
|---|---|---|
| committer | Aaron Davidson <aaron@databricks.com> | 2013-10-20 11:03:36 -0700 |
| commit | 38b8048f291dd42ee996e75bd1b6d33aa24b1a5e (patch) | |
| tree | 08a0dd33ebececec11f4db9a6686a5f64edc472f /core/src/main | |
| parent | 136b9b3a3ed358bc04b28e8d62657d56d55c2c3e (diff) | |
| download | spark-38b8048f291dd42ee996e75bd1b6d33aa24b1a5e.tar.gz spark-38b8048f291dd42ee996e75bd1b6d33aa24b1a5e.tar.bz2 spark-38b8048f291dd42ee996e75bd1b6d33aa24b1a5e.zip | |
Fix compiler errors
Whoops. Last-second changes require testing too, it seems.
Diffstat (limited to 'core/src/main')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala index d84f5968df..c890a1f04a 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala @@ -521,7 +521,7 @@ class DAGScheduler( val rdd = job.finalStage.rdd val split = rdd.partitions(job.partitions(0)) val taskContext = - new TaskContext(job.finalStage.id, job.partitions(0), 0, runningLocally = true) + new TaskContext(job.finalStage.id, job.partitions(0), 0, "local", runningLocally = true) try { val result = job.func(taskContext, rdd.iterator(split, taskContext)) job.listener.taskSucceeded(0, result) |