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:50 UTC
[6/8] git commit: objectSer -> valueSer in a test.
objectSer -> valueSer in a test.
Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/717c7fdd
Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/717c7fdd
Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/717c7fdd
Branch: refs/heads/master
Commit: 717c7fddb27a3ec8732a760c000bbfa7060d76c1
Parents: b2f0329
Author: Tor Myklebust <tm...@gmail.com>
Authored: Tue Dec 17 23:02:21 2013 -0500
Committer: Tor Myklebust <tm...@gmail.com>
Committed: Tue Dec 17 23:02:21 2013 -0500
----------------------------------------------------------------------
.../spark/scheduler/cluster/ClusterTaskSetManagerSuite.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/717c7fdd/core/src/test/scala/org/apache/spark/scheduler/cluster/ClusterTaskSetManagerSuite.scala
----------------------------------------------------------------------
diff --git a/core/src/test/scala/org/apache/spark/scheduler/cluster/ClusterTaskSetManagerSuite.scala b/core/src/test/scala/org/apache/spark/scheduler/cluster/ClusterTaskSetManagerSuite.scala
index cb719d7..bb28a31 100644
--- a/core/src/test/scala/org/apache/spark/scheduler/cluster/ClusterTaskSetManagerSuite.scala
+++ b/core/src/test/scala/org/apache/spark/scheduler/cluster/ClusterTaskSetManagerSuite.scala
@@ -313,7 +313,7 @@ class ClusterTaskSetManagerSuite extends FunSuite with LocalSparkContext with Lo
}
def createTaskResult(id: Int): DirectTaskResult[Int] = {
- val objectSer = SparkEnv.get.serializer.newInstance()
- new DirectTaskResult[Int](objectSer.serialize(id), mutable.Map.empty, new TaskMetrics)
+ val valueSer = SparkEnv.get.serializer.newInstance()
+ new DirectTaskResult[Int](valueSer.serialize(id), mutable.Map.empty, new TaskMetrics)
}
}