Github user gaborgsomogyi commented on a diff in the pull request:
https://github.com/apache/spark/pull/19893#discussion_r154958833
--- Diff:
core/src/test/scala/org/apache/spark/scheduler/TaskSetManagerSuite.scala ---
@@ -683,7 +683,7 @@ class TaskSetManagerSuite extends SparkFunSuite with
LocalSparkContext with Logg
val conf = new SparkConf().set("spark.speculation", "true")
sc = new SparkContext("local", "test", conf)
- val sched = new FakeTaskScheduler(sc, ("execA", "host1"), ("execB",
"host2"))
+ sched = new FakeTaskScheduler(sc, ("execA", "host1"), ("execB",
"host2"))
--- End diff --
Here originally the newly created instance was stored in a local variable
which was never saved in member and freed properly. With this change the
afterEach method stops it and frees up the resources.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
