Skip to content

Commit bb6dbd2

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 38ade42 commit bb6dbd2

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
@@ -130,7 +130,7 @@ private[spark] class MesosClusterScheduler(
130130
private val queuedCapacity = conf.getInt("spark.mesos.maxDrivers", 200)
131131
private val retainedDrivers = conf.getInt("spark.mesos.retainedDrivers", 200)
132132
private val maxRetryWaitTime = conf.getInt("spark.mesos.cluster.retry.wait.max", 60) // 1 minute
133-
private val useFetchCache = conf.getBoolean("spark.mesos.fetchCache.enable", false)
133+
private val useFetchCache = conf.getBoolean("spark.mesos.fetcherCache.enable", false)
134134
private val schedulerState = engineFactory.createEngine("scheduler")
135135
private val stateLock = new Object()
136136
// Keyed by submission id

0 commit comments

Comments
 (0)