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:51 UTC
[spark] branch revert-28307-locality-fix created (now 1243ec0)
This is an automated email from the ASF dual-hosted git repository.
tgraves pushed a change to branch revert-28307-locality-fix
in repository https://gitbox.apache.org/repos/asf/spark.git.
at 1243ec0 Revert "fix version for config spark.locality.wait.legacyResetOnTaskLaunch (#28307)"
This branch includes the following new commits:
new 1243ec0 Revert "fix version for config spark.locality.wait.legacyResetOnTaskLaunch (#28307)"
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org
[spark] 01/01: Revert "fix version for config
spark.locality.wait.legacyResetOnTaskLaunch (#28307)"
Posted by tg...@apache.org.
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