diff --git a/core/src/main/scala/org/apache/spark/internal/config/package.scala b/core/src/main/scala/org/apache/spark/internal/config/package.scala index 981d5f9e0c5b8..5006da081b2f7 100644 --- a/core/src/main/scala/org/apache/spark/internal/config/package.scala +++ b/core/src/main/scala/org/apache/spark/internal/config/package.scala @@ -550,7 +550,7 @@ package object config { "anytime a task is scheduled. See Delay Scheduling section of TaskSchedulerImpl's class " + "documentation for more details.") .internal() - .version("3.0.0") + .version("3.1.0") .booleanConf .createWithDefault(false) 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 d327099197dc9..d1fc3a597a070 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala @@ -356,7 +356,7 @@ private[spark] class TaskSchedulerImpl( * value at index 'i' corresponds to shuffledOffers[i] * @param tasks tasks scheduled per offer, value at index 'i' corresponds to shuffledOffers[i] * @param addressesWithDescs tasks scheduler per host:port, used for barrier tasks - * @return tuple of (had delay schedule rejects?, option of min locality of launched task) + * @return tuple of (no delay schedule rejects?, option of min locality of launched task) */ private def resourceOfferSingleTaskSet( taskSet: TaskSetManager,