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 07d720c commit 0921ea0Copy full SHA for 0921ea0
core/src/main/scala/org/apache/spark/scheduler/Pool.scala
@@ -37,8 +37,8 @@ private[spark] class Pool(
37
extends Schedulable
38
with Logging {
39
40
- var schedulableQueue = new LinkedBlockingQueue[Schedulable]
41
- var schedulableNameToSchedulable = new ConcurrentHashMap[String, Schedulable]
+ val schedulableQueue = new LinkedBlockingQueue[Schedulable]
+ val schedulableNameToSchedulable = new ConcurrentHashMap[String, Schedulable]
42
var weight = initWeight
43
var minShare = initMinShare
44
var runningTasks = 0
0 commit comments