File tree Expand file tree Collapse file tree 1 file changed +5
-1
lines changed
yarn/src/main/scala/org/apache/spark/deploy/yarn Expand file tree Collapse file tree 1 file changed +5
-1
lines changed Original file line number Diff line number Diff line change @@ -373,7 +373,11 @@ private[yarn] class YarnAllocator(
373373 // Hadoop 2.2.X added a ContainerExitStatus we should switch to use
374374 // there are some exit status' we shouldn't necessarily count against us, but for
375375 // now I think its ok as none of the containers are expected to exit
376- if (completedContainer.getExitStatus == - 103 ) { // vmem limit exceeded
376+ if (completedContainer.getExitStatus == ContainerExitStatus .PREEMPTED ) {
377+ logInfo(" Container killed: " + containerId +
378+ " . Exit status: " + completedContainer.getExitStatus +
379+ " . Diagnostics: " + completedContainer.getDiagnostics)
380+ } else if (completedContainer.getExitStatus == - 103 ) { // vmem limit exceeded
377381 logWarning(memLimitExceededLogMessage(
378382 completedContainer.getDiagnostics,
379383 VMEM_EXCEEDED_PATTERN ))
You can’t perform that action at this time.
0 commit comments