Skip to content

Commit 1090b58

Browse files
committed
Change flag name
1 parent 77ce7d8 commit 1090b58

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -138,7 +138,7 @@ class DAGScheduler(
138138
taskScheduler.setDAGScheduler(this)
139139

140140
// Flag to control if reduce tasks are assigned preferred locations
141-
private val shuffleLocalityEnabled = sc.getConf.getBoolean("spark.shuffle.locality.enabled", true)
141+
private val shuffleLocalityEnabled = sc.getConf.getBoolean("spark.shuffle.reduceLocality.enabled", true)
142142
// Number of map, reduce tasks above which we do not assign preferred locations
143143
// based on map output sizes. We limit the size of jobs for which assign preferred locations
144144
// as sorting the locations by size becomes expensive.

0 commit comments

Comments
 (0)