You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by do...@apache.org on 2019/02/07 09:23:33 UTC
[spark] branch branch-2.3 updated: [SPARK-26082][MESOS] Fix mesos
fetch cache config name
This is an automated email from the ASF dual-hosted git repository.
dongjoon pushed a commit to branch branch-2.3
in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/branch-2.3 by this push:
new bb6dbd2 [SPARK-26082][MESOS] Fix mesos fetch cache config name
bb6dbd2 is described below
commit bb6dbd23f6b594e7ac361ff605f8b1ed18877aa3
Author: mwlon <ml...@hmc.edu>
AuthorDate: Thu Feb 7 01:21:31 2019 -0800
[SPARK-26082][MESOS] Fix mesos fetch cache config name
## What changes were proposed in this pull request?
* change MesosClusterScheduler to use correct argument name for Mesos fetch cache (spark.mesos.fetchCache.enable -> spark.mesos.fetcherCache.enable)
## How was this patch tested?
Not sure this requires a test, since it's just a string change.
Closes #23734 from mwlon/SPARK-26082.
Authored-by: mwlon <ml...@hmc.edu>
Signed-off-by: Dongjoon Hyun <dh...@apple.com>
(cherry picked from commit c0811e8b4d11892f60b7032ba4c8e3adc40fe82f)
Signed-off-by: Dongjoon Hyun <dh...@apple.com>
---
.../apache/spark/scheduler/cluster/mesos/MesosClusterScheduler.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/resource-managers/mesos/src/main/scala/org/apache/spark/scheduler/cluster/mesos/MesosClusterScheduler.scala b/resource-managers/mesos/src/main/scala/org/apache/spark/scheduler/cluster/mesos/MesosClusterScheduler.scala
index b36f464..9306f80 100644
--- a/resource-managers/mesos/src/main/scala/org/apache/spark/scheduler/cluster/mesos/MesosClusterScheduler.scala
+++ b/resource-managers/mesos/src/main/scala/org/apache/spark/scheduler/cluster/mesos/MesosClusterScheduler.scala
@@ -130,7 +130,7 @@ private[spark] class MesosClusterScheduler(
private val queuedCapacity = conf.getInt("spark.mesos.maxDrivers", 200)
private val retainedDrivers = conf.getInt("spark.mesos.retainedDrivers", 200)
private val maxRetryWaitTime = conf.getInt("spark.mesos.cluster.retry.wait.max", 60) // 1 minute
- private val useFetchCache = conf.getBoolean("spark.mesos.fetchCache.enable", false)
+ private val useFetchCache = conf.getBoolean("spark.mesos.fetcherCache.enable", false)
private val schedulerState = engineFactory.createEngine("scheduler")
private val stateLock = new Object()
// Keyed by submission id
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org