You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by tg...@apache.org on 2020/04/23 19:41:52 UTC
[spark] 01/01: Revert "fix version for config
spark.locality.wait.legacyResetOnTaskLaunch (#28307)"
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 <tg...@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-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org