This is an automated email from the ASF dual-hosted git repository. tgraves pushed a commit to branch revert-28307-locality-fix in repository https://gitbox.apache.org/repos/asf/spark.git
commit 1243ec0cd06d5fd9b0ccd8c850bd1c3df2603534 Author: Thomas Graves <tgra...@apache.org> AuthorDate: Thu Apr 23 14:38:48 2020 -0500 Revert "fix version for config spark.locality.wait.legacyResetOnTaskLaunch (#28307)" This reverts commit f093480af99063ad89273ffb3bf97d61269611e4. --- core/src/main/scala/org/apache/spark/internal/config/package.scala | 2 +- core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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 5006da0..981d5f9 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.1.0") + .version("3.0.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 d1fc3a5..d327099 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 (no delay schedule rejects?, option of min locality of launched task) + * @return tuple of (had delay schedule rejects?, option of min locality of launched task) */ private def resourceOfferSingleTaskSet( taskSet: TaskSetManager, --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org