aboutsummaryrefslogtreecommitdiff
path: root/yarn
diff options
context:
space:
mode:
authorYadong Qi <qiyadong2010@gmail.com>2015-08-09 19:54:05 +0100
committerSean Owen <sowen@cloudera.com>2015-08-09 19:54:05 +0100
commit86fa4ba6d13f909cb508b7cb3b153d586fe59bc3 (patch)
tree7de0f76080b6178161b2ae412b13ab7a628cf86f /yarn
parent68ccc6e184598822b19a880fdd4597b66a1c2d92 (diff)
downloadspark-86fa4ba6d13f909cb508b7cb3b153d586fe59bc3.tar.gz
spark-86fa4ba6d13f909cb508b7cb3b153d586fe59bc3.tar.bz2
spark-86fa4ba6d13f909cb508b7cb3b153d586fe59bc3.zip
[SPARK-9737] [YARN] Add the suggested configuration when required executor memory is above the max threshold of this cluster on YARN mode
Author: Yadong Qi <qiyadong2010@gmail.com> Closes #8028 from watermen/SPARK-9737 and squashes the following commits: 48bdf3d [Yadong Qi] Add suggested configuration.
Diffstat (limited to 'yarn')
-rw-r--r--yarn/src/main/scala/org/apache/spark/deploy/yarn/Client.scala6
1 files changed, 4 insertions, 2 deletions
diff --git a/yarn/src/main/scala/org/apache/spark/deploy/yarn/Client.scala b/yarn/src/main/scala/org/apache/spark/deploy/yarn/Client.scala
index fc11bbf97e..b4ba3f0221 100644
--- a/yarn/src/main/scala/org/apache/spark/deploy/yarn/Client.scala
+++ b/yarn/src/main/scala/org/apache/spark/deploy/yarn/Client.scala
@@ -203,12 +203,14 @@ private[spark] class Client(
val executorMem = args.executorMemory + executorMemoryOverhead
if (executorMem > maxMem) {
throw new IllegalArgumentException(s"Required executor memory (${args.executorMemory}" +
- s"+$executorMemoryOverhead MB) is above the max threshold ($maxMem MB) of this cluster!")
+ s"+$executorMemoryOverhead MB) is above the max threshold ($maxMem MB) of this cluster! " +
+ "Please increase the value of 'yarn.scheduler.maximum-allocation-mb'.")
}
val amMem = args.amMemory + amMemoryOverhead
if (amMem > maxMem) {
throw new IllegalArgumentException(s"Required AM memory (${args.amMemory}" +
- s"+$amMemoryOverhead MB) is above the max threshold ($maxMem MB) of this cluster!")
+ s"+$amMemoryOverhead MB) is above the max threshold ($maxMem MB) of this cluster! " +
+ "Please increase the value of 'yarn.scheduler.maximum-allocation-mb'.")
}
logInfo("Will allocate AM container, with %d MB memory including %d MB overhead".format(
amMem,