Skip to content

Commit 7551cbd

Browse files
Review comments are addressed.
1 parent 558f8b1 commit 7551cbd

File tree

1 file changed

+10
-4
lines changed

1 file changed

+10
-4
lines changed

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

Lines changed: 10 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -115,8 +115,11 @@ private[spark] class FairSchedulableBuilder(val rootPool: Pool, conf: SparkConf)
115115
}
116116
}
117117

118-
private def getSchedulingModeValue(poolNode: Node, poolName: String, defaultValue: SchedulingMode)
119-
: SchedulingMode = {
118+
private def getSchedulingModeValue(
119+
poolNode: Node,
120+
poolName: String,
121+
defaultValue: SchedulingMode): SchedulingMode = {
122+
120123
val xmlSchedulingMode = (poolNode \ SCHEDULING_MODE_PROPERTY).text.trim.toUpperCase
121124
val warningMessage = s"Unsupported schedulingMode: $xmlSchedulingMode, using the default " +
122125
s"schedulingMode: $defaultValue for pool: $poolName"
@@ -134,8 +137,11 @@ private[spark] class FairSchedulableBuilder(val rootPool: Pool, conf: SparkConf)
134137
}
135138
}
136139

137-
private def getIntValue(poolNode: Node, poolName: String, propertyName: String, defaultValue: Int)
138-
: Int = {
140+
private def getIntValue(
141+
poolNode: Node,
142+
poolName: String,
143+
propertyName: String, defaultValue: Int): Int = {
144+
139145
val data = (poolNode \ propertyName).text.trim
140146
try {
141147
data.toInt

0 commit comments

Comments
 (0)