diff options
| author | Reynold Xin <reynoldx@gmail.com> | 2013-09-07 21:59:47 +0800 |
|---|---|---|
| committer | Reynold Xin <reynoldx@gmail.com> | 2013-09-07 21:59:47 +0800 |
| commit | 210eae26f4121d772210ffa0494689c911771456 (patch) | |
| tree | 1edbed018a0a0b8b65bff9868c3ceeee1a6f1219 /core | |
| parent | 2eebeff5ebe86509adb2a0f18521d1648ea38008 (diff) | |
| download | spark-210eae26f4121d772210ffa0494689c911771456.tar.gz spark-210eae26f4121d772210ffa0494689c911771456.tar.bz2 spark-210eae26f4121d772210ffa0494689c911771456.zip | |
Fixed the bug that ResultTask was not properly deserializing outputId.
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/scheduler/ResultTask.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/core/src/main/scala/org/apache/spark/scheduler/ResultTask.scala b/core/src/main/scala/org/apache/spark/scheduler/ResultTask.scala index ca44ebb189..07e8317e3a 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/ResultTask.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/ResultTask.scala @@ -77,7 +77,7 @@ private[spark] class ResultTask[T, U]( var func: (TaskContext, Iterator[T]) => U, var partition: Int, @transient locs: Seq[TaskLocation], - val outputId: Int) + var outputId: Int) extends Task[U](stageId) with Externalizable { def this() = this(0, null, null, 0, null, 0) @@ -130,7 +130,7 @@ private[spark] class ResultTask[T, U]( rdd = rdd_.asInstanceOf[RDD[T]] func = func_.asInstanceOf[(TaskContext, Iterator[T]) => U] partition = in.readInt() - val outputId = in.readInt() + outputId = in.readInt() epoch = in.readLong() split = in.readObject().asInstanceOf[Partition] } |