diff --git a/core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala b/core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala index ef3a558d54bd..b48ba127ce4b 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala @@ -128,7 +128,7 @@ private[spark] class TaskSchedulerImpl( @volatile private var hasReceivedTask = false @volatile private var hasLaunchedTask = false - private val starvationTimer = new Timer(true) + private val starvationTimer = new Timer("task-starvation-timer", true) // Incrementing task IDs val nextTaskId = new AtomicLong(0) @@ -152,7 +152,7 @@ private[spark] class TaskSchedulerImpl( protected val executorIdToHost = new HashMap[String, String] - private val abortTimer = new Timer(true) + private val abortTimer = new Timer("task-abort-timer", true) // Exposed for testing val unschedulableTaskSetToExpiryTime = new HashMap[TaskSetManager, Long]