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 0921ea0 commit 05ad9e9Copy full SHA for 05ad9e9
core/src/main/scala/org/apache/spark/scheduler/Pool.scala
@@ -70,7 +70,7 @@ private[spark] class Pool(
70
}
71
72
override def getSchedulableByName(schedulableName: String): Schedulable = {
73
- if (schedulableNameToSchedulable.contains(schedulableName)) {
+ if (schedulableNameToSchedulable.containsKey(schedulableName)) {
74
return schedulableNameToSchedulable.get(schedulableName)
75
76
for (schedulable <- schedulableQueue.asScala) {
0 commit comments