You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by pw...@apache.org on 2013/12/20 03:12:49 UTC
[5/8] git commit: Missed a spot; had an objectSer here too.
Missed a spot; had an objectSer here too.
Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/b2f03295
Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/b2f03295
Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/b2f03295
Branch: refs/heads/master
Commit: b2f0329511f3caaf473cf300792690703a300a22
Parents: 25fa976
Author: Tor Myklebust <tm...@gmail.com>
Authored: Tue Dec 17 00:18:46 2013 -0500
Committer: Tor Myklebust <tm...@gmail.com>
Committed: Tue Dec 17 00:18:46 2013 -0500
----------------------------------------------------------------------
core/src/main/scala/org/apache/spark/scheduler/TaskResult.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/b2f03295/core/src/main/scala/org/apache/spark/scheduler/TaskResult.scala
----------------------------------------------------------------------
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 4e00bc8..e80cc6b 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)
}
}