diff options
| author | Tor Myklebust <tmyklebu@gmail.com> | 2013-12-17 00:18:46 -0500 |
|---|---|---|
| committer | Tor Myklebust <tmyklebu@gmail.com> | 2013-12-17 00:18:46 -0500 |
| commit | b2f0329511f3caaf473cf300792690703a300a22 (patch) | |
| tree | d2bb092be7725d90f149d6409883dcfdec163f75 | |
| parent | 25fa97658013c02a5926b44a74de3db14488a227 (diff) | |
| download | spark-b2f0329511f3caaf473cf300792690703a300a22.tar.gz spark-b2f0329511f3caaf473cf300792690703a300a22.tar.bz2 spark-b2f0329511f3caaf473cf300792690703a300a22.zip | |
Missed a spot; had an objectSer here too.
| -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) } } |