fix tests

apache · Sep 19, 2019 · d1e744e · d1e744e
1 parent 82740d0
commit d1e744e
Showing 1 changed file with 1 addition and 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
@@ -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