File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed
yarn/src/main/scala/org/apache/spark/deploy/yarn Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -203,12 +203,14 @@ private[spark] class Client(
203
203
val executorMem = args.executorMemory + executorMemoryOverhead
204
204
if (executorMem > maxMem) {
205
205
throw new IllegalArgumentException (s " Required executor memory ( ${args.executorMemory}" +
206
- s " + $executorMemoryOverhead MB) is above the max threshold ( $maxMem MB) of this cluster! " )
206
+ s " + $executorMemoryOverhead MB) is above the max threshold ( $maxMem MB) of this cluster! " +
207
+ " Please increase the value of 'yarn.scheduler.maximum-allocation-mb'." )
207
208
}
208
209
val amMem = args.amMemory + amMemoryOverhead
209
210
if (amMem > maxMem) {
210
211
throw new IllegalArgumentException (s " Required AM memory ( ${args.amMemory}" +
211
- s " + $amMemoryOverhead MB) is above the max threshold ( $maxMem MB) of this cluster! " )
212
+ s " + $amMemoryOverhead MB) is above the max threshold ( $maxMem MB) of this cluster! " +
213
+ " Please increase the value of 'yarn.scheduler.maximum-allocation-mb'." )
212
214
}
213
215
logInfo(" Will allocate AM container, with %d MB memory including %d MB overhead" .format(
214
216
amMem,
You can’t perform that action at this time.
0 commit comments