diff options
| author | derek ma <maji3@asiainfo-linkage.com> | 2014-07-30 21:37:59 -0700 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2014-07-30 21:37:59 -0700 |
| commit | 118c1c422d3dfbfb2277995062678f0a808af6c3 (patch) | |
| tree | 4b05a639767e081509df34aea384b86276396460 /yarn | |
| parent | 894d48ffb8c91e347ab60c58de983e1aaf181188 (diff) | |
| download | spark-118c1c422d3dfbfb2277995062678f0a808af6c3.tar.gz spark-118c1c422d3dfbfb2277995062678f0a808af6c3.tar.bz2 spark-118c1c422d3dfbfb2277995062678f0a808af6c3.zip | |
Required AM memory is "amMem", not "args.amMemory"
"ERROR yarn.Client: Required AM memory (1024) is above the max threshold (1048) of this cluster" appears if this code is not changed. obviously, 1024 is less than 1048, so change this
Author: derek ma <maji3@asiainfo-linkage.com>
Closes #1494 from maji2014/master and squashes the following commits:
b0f6640 [derek ma] Required AM memory is "amMem", not "args.amMemory"
Diffstat (limited to 'yarn')
| -rw-r--r-- | yarn/common/src/main/scala/org/apache/spark/deploy/yarn/ClientBase.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/yarn/common/src/main/scala/org/apache/spark/deploy/yarn/ClientBase.scala b/yarn/common/src/main/scala/org/apache/spark/deploy/yarn/ClientBase.scala index a1298e8f30..b7e8636e02 100644 --- a/yarn/common/src/main/scala/org/apache/spark/deploy/yarn/ClientBase.scala +++ b/yarn/common/src/main/scala/org/apache/spark/deploy/yarn/ClientBase.scala @@ -109,7 +109,7 @@ trait ClientBase extends Logging { if (amMem > maxMem) { val errorMessage = "Required AM memory (%d) is above the max threshold (%d) of this cluster." - .format(args.amMemory, maxMem) + .format(amMem, maxMem) logError(errorMessage) throw new IllegalArgumentException(errorMessage) } |