Skip to content

Commit

Permalink
Update ClientArguments.scala
Browse files Browse the repository at this point in the history
  • Loading branch information
XuTingjun committed Dec 25, 2014
1 parent b4d0db8 commit 5a780fc
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -39,6 +39,8 @@ private[spark] class ClientArguments(args: Array[String], sparkConf: SparkConf)
var appName: String = "Spark"
var priority = 0

parseArgs(args.toList)

// Additional memory to allocate to containers
// For now, use driver's memory overhead as our AM container's memory overhead
val amMemoryOverhead = sparkConf.getInt("spark.yarn.driver.memoryOverhead",
Expand All @@ -50,7 +52,6 @@ private[spark] class ClientArguments(args: Array[String], sparkConf: SparkConf)
private val isDynamicAllocationEnabled =
sparkConf.getBoolean("spark.dynamicAllocation.enabled", false)

parseArgs(args.toList)
loadEnvironmentArgs()
validateArgs()

Expand Down

0 comments on commit 5a780fc

Please sign in to comment.