From b2f0329511f3caaf473cf300792690703a300a22 Mon Sep 17 00:00:00 2001 From: Tor Myklebust Date: Tue, 17 Dec 2013 00:18:46 -0500 Subject: Missed a spot; had an objectSer here too. --- core/src/main/scala/org/apache/spark/scheduler/TaskResult.scala | 4 ++-- 1 file 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) } } -- cgit v1.2.3