Github user squito commented on a diff in the pull request:
https://github.com/apache/spark/pull/22288#discussion_r227061320
--- Diff:
core/src/test/scala/org/apache/spark/scheduler/TaskSchedulerImplSuite.scala ---
@@ -82,10 +84,12 @@ class TaskSchedulerImplSuite extends SparkFunSuite with
LocalSparkContext with B
setupHelper()
}
- def setupSchedulerWithMockTaskSetBlacklist(): TaskSchedulerImpl = {
+ def setupSchedulerWithMockTaskSetBlacklist(confs: (String, String)*):
TaskSchedulerImpl = {
blacklist = mock[BlacklistTracker]
val conf = new
SparkConf().setMaster("local").setAppName("TaskSchedulerImplSuite")
conf.set(config.BLACKLIST_ENABLED, true)
+ confs.foreach{ case (k, v) => conf.set(k, v) }
--- End diff --
super nit: space before `{`
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
