From d1e744eca601d75770011b08d39cc09fa8bcab89 Mon Sep 17 00:00:00 2001 From: Daoyuan Wang Date: Thu, 19 Sep 2019 20:14:35 +0800 Subject: [PATCH] fix tests --- .../org/apache/spark/scheduler/TaskResultGetterSuite.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/test/scala/org/apache/spark/scheduler/TaskResultGetterSuite.scala b/core/src/test/scala/org/apache/spark/scheduler/TaskResultGetterSuite.scala index a8f975609134f..187bc2ae83e67 100644 --- a/core/src/test/scala/org/apache/spark/scheduler/TaskResultGetterSuite.scala +++ b/core/src/test/scala/org/apache/spark/scheduler/TaskResultGetterSuite.scala @@ -146,7 +146,7 @@ class TaskResultGetterSuite extends SparkFunSuite with BeforeAndAfter with Local val scheduler = new DummyTaskSchedulerImpl(sc) val spyScheduler = spy(scheduler) val resultGetter = new TaskResultGetter(sc.env, spyScheduler) - spyScheduler.taskResultGetter = resultGetter + scheduler.taskResultGetter = resultGetter val myTsm = new TaskSetManager(spyScheduler, FakeTask.createTaskSet(2), 1) { // always returns false override def canFetchMoreResults(size: Long): Boolean = false