diff options
| author | Tor Myklebust <tmyklebu@gmail.com> | 2013-12-17 23:02:21 -0500 |
|---|---|---|
| committer | Tor Myklebust <tmyklebu@gmail.com> | 2013-12-17 23:02:21 -0500 |
| commit | 717c7fddb27a3ec8732a760c000bbfa7060d76c1 (patch) | |
| tree | 407b6584903e917a15057bb6215a5dc05470134e | |
| parent | b2f0329511f3caaf473cf300792690703a300a22 (diff) | |
| download | spark-717c7fddb27a3ec8732a760c000bbfa7060d76c1.tar.gz spark-717c7fddb27a3ec8732a760c000bbfa7060d76c1.tar.bz2 spark-717c7fddb27a3ec8732a760c000bbfa7060d76c1.zip | |
objectSer -> valueSer in a test.
| -rw-r--r-- | core/src/test/scala/org/apache/spark/scheduler/cluster/ClusterTaskSetManagerSuite.scala | 4 |
1 files changed, 2 insertions, 2 deletions
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 cb719d7ab9..bb28a31a99 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) } } |