diff options
| author | Tor Myklebust <tmyklebu@csclub.uwaterloo.ca> | 2013-12-16 12:07:39 -0500 |
|---|---|---|
| committer | Tor Myklebust <tmyklebu@csclub.uwaterloo.ca> | 2013-12-16 12:07:39 -0500 |
| commit | 8a397a959bf0b68f7d10fa57665225e0c2b5d03a (patch) | |
| tree | 409ea16382dd7cc3b3e26dfe31d88de1c9c7f9cf /core/src/test/scala/org | |
| parent | a51f3404ad8711f5fe66381122c5fa1ead09b3da (diff) | |
| download | spark-8a397a959bf0b68f7d10fa57665225e0c2b5d03a.tar.gz spark-8a397a959bf0b68f7d10fa57665225e0c2b5d03a.tar.bz2 spark-8a397a959bf0b68f7d10fa57665225e0c2b5d03a.zip | |
Track task value serialisation time in TaskMetrics.
Diffstat (limited to 'core/src/test/scala/org')
| -rw-r--r-- | core/src/test/scala/org/apache/spark/scheduler/cluster/ClusterTaskSetManagerSuite.scala | 4 |
1 files changed, 3 insertions, 1 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 b97f2b19b5..788cbb81bf 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,6 +313,8 @@ class ClusterTaskSetManagerSuite extends FunSuite with LocalSparkContext with Lo } def createTaskResult(id: Int): DirectTaskResult[Int] = { - new DirectTaskResult[Int](id, mutable.Map.empty, new TaskMetrics) + val objectSer = SparkEnv.get.serializer.newInstance() + new DirectTaskResult[Int](objectSer.serialize(id), mutable.Map.empty, + new TaskMetrics) } } |