diff options
| -rw-r--r-- | core/src/main/scala/org/apache/spark/scheduler/TaskResult.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/core/src/main/scala/org/apache/spark/scheduler/TaskResult.scala b/core/src/main/scala/org/apache/spark/scheduler/TaskResult.scala index 4e00bc8271..e80cc6b0f6 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/TaskResult.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/TaskResult.scala @@ -73,7 +73,7 @@ class DirectTaskResult[T](var valueBytes: ByteBuffer, var accumUpdates: Map[Long } def value(): T = { - val objectSer = SparkEnv.get.serializer.newInstance() - return objectSer.deserialize(valueBytes) + val resultSer = SparkEnv.get.serializer.newInstance() + return resultSer.deserialize(valueBytes) } } |