Skip to content

Commit c41a5e1

Browse files
mwlondongjoon-hyun
authored andcommitted
[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 <[email protected]> Signed-off-by: Dongjoon Hyun <[email protected]> (cherry picked from commit c0811e8) Signed-off-by: Dongjoon Hyun <[email protected]>
1 parent 9b2eedc commit c41a5e1

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

resource-managers/mesos/src/main/scala/org/apache/spark/scheduler/cluster/mesos/MesosClusterScheduler.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -129,7 +129,7 @@ private[spark] class MesosClusterScheduler(
129129
private val queuedCapacity = conf.getInt("spark.mesos.maxDrivers", 200)
130130
private val retainedDrivers = conf.getInt("spark.mesos.retainedDrivers", 200)
131131
private val maxRetryWaitTime = conf.getInt("spark.mesos.cluster.retry.wait.max", 60) // 1 minute
132-
private val useFetchCache = conf.getBoolean("spark.mesos.fetchCache.enable", false)
132+
private val useFetchCache = conf.getBoolean("spark.mesos.fetcherCache.enable", false)
133133
private val schedulerState = engineFactory.createEngine("scheduler")
134134
private val stateLock = new Object()
135135
// Keyed by submission id

0 commit comments

Comments
 (0)