We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 167fad8 commit 5ff59c2Copy full SHA for 5ff59c2
core/src/test/scala/org/apache/spark/scheduler/TaskSetManagerSuite.scala
@@ -301,7 +301,7 @@ class TaskSetManagerSuite extends FunSuite with LocalSparkContext with Logging {
301
test("executors should be blacklisted after task failure, in spite of locality preferences") {
302
val rescheduleDelay = 300L
303
val conf = new SparkConf().
304
- set("spark.task.executorBlacklistTimeout", rescheduleDelay.toString).
+ set("spark.scheduler.executorTaskBlacklistTime", rescheduleDelay.toString).
305
// dont wait to jump locality levels in this test
306
set("spark.locality.wait", "0")
307
0 commit comments