We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1090b58 commit 68bc29eCopy full SHA for 68bc29e
core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
@@ -138,7 +138,8 @@ class DAGScheduler(
138
taskScheduler.setDAGScheduler(this)
139
140
// Flag to control if reduce tasks are assigned preferred locations
141
- private val shuffleLocalityEnabled = sc.getConf.getBoolean("spark.shuffle.reduceLocality.enabled", true)
+ private val shuffleLocalityEnabled =
142
+ sc.getConf.getBoolean("spark.shuffle.reduceLocality.enabled", true)
143
// Number of map, reduce tasks above which we do not assign preferred locations
144
// based on map output sizes. We limit the size of jobs for which assign preferred locations
145
// as sorting the locations by size becomes expensive.
0 commit comments