You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by tg...@apache.org on 2014/12/29 15:20:30 UTC
spark git commit: [SPARK-4966][YARN]The MemoryOverhead value is
setted not correctly
Repository: spark
Updated Branches:
refs/heads/master a3e51cc99 -> 14fa87bdf
[SPARK-4966][YARN]The MemoryOverhead value is setted not correctly
Author: meiyoula <10...@qq.com>
Closes #3797 from XuTingjun/MemoryOverhead and squashes the following commits:
5a780fc [meiyoula] Update ClientArguments.scala
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/14fa87bd
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/14fa87bd
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/14fa87bd
Branch: refs/heads/master
Commit: 14fa87bdf4b89cd392270864ee063ce01bd31887
Parents: a3e51cc
Author: meiyoula <10...@qq.com>
Authored: Mon Dec 29 08:20:30 2014 -0600
Committer: Thomas Graves <tg...@apache.org>
Committed: Mon Dec 29 08:20:30 2014 -0600
----------------------------------------------------------------------
.../main/scala/org/apache/spark/deploy/yarn/ClientArguments.scala | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/14fa87bd/yarn/src/main/scala/org/apache/spark/deploy/yarn/ClientArguments.scala
----------------------------------------------------------------------
diff --git a/yarn/src/main/scala/org/apache/spark/deploy/yarn/ClientArguments.scala b/yarn/src/main/scala/org/apache/spark/deploy/yarn/ClientArguments.scala
index 7305249..39f1021 100644
--- a/yarn/src/main/scala/org/apache/spark/deploy/yarn/ClientArguments.scala
+++ b/yarn/src/main/scala/org/apache/spark/deploy/yarn/ClientArguments.scala
@@ -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",
@@ -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()
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org