Skip to content

Commit 4ef1cbd

Browse files
committed
review commit
1 parent 49ef70e commit 4ef1cbd

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

core/src/main/scala/org/apache/spark/deploy/worker/WorkerArguments.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -54,14 +54,15 @@ private[spark] class WorkerArguments(args: Array[String], conf: SparkConf) {
5454

5555
parse(args.toList)
5656

57-
checkWorkerMemory()
5857
// This mutates the SparkConf, so all accesses to it must be made after this line
5958
propertiesFile = Utils.loadDefaultSparkProperties(conf, propertiesFile)
6059

6160
if (conf.contains("spark.worker.ui.port")) {
6261
webUiPort = conf.get("spark.worker.ui.port").toInt
6362
}
6463

64+
checkWorkerMemory()
65+
6566
def parse(args: List[String]): Unit = args match {
6667
case ("--ip" | "-i") :: value :: tail =>
6768
Utils.checkHost(value, "ip no longer supported, please use hostname " + value)

0 commit comments

Comments
 (0)