File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
core/src/main/scala/org/apache/spark Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -79,6 +79,9 @@ private[spark] class ExecutorAllocationManager(sc: SparkContext) extends Logging
7979 private val executorIdleTimeout = conf.getLong(
8080 " spark.dynamicAllocation.executorIdleTimeout" , 600 )
8181
82+ // Whether we are testing this class. This should only be used internally.
83+ private val testing = conf.getBoolean(" spark.dynamicAllocation.testing" , false )
84+
8285 validateSettings()
8386
8487 // Number of executors to add in the next round
@@ -104,9 +107,6 @@ private[spark] class ExecutorAllocationManager(sc: SparkContext) extends Logging
104107 // Polling loop interval (ms)
105108 private val intervalMillis : Long = 100
106109
107- // Whether we are testing this class. This should only be used internally.
108- private val testing = conf.getBoolean(" spark.dynamicAllocation.testing" , false )
109-
110110 // Clock used to schedule when executors should be added and removed
111111 private var clock : Clock = new RealClock
112112
You can’t perform that action at this time.
0 commit comments