From f0b65199f50bae99aa89ea3a5915b610d7134392 Mon Sep 17 00:00:00 2001 From: Thomas Graves Date: Mon, 29 Sep 2014 10:05:29 -0500 Subject: [PATCH] change order of cleanup staging dir --- .../scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/yarn/common/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala b/yarn/common/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala index 87aa9f18c09a5..94f2a644bfe4f 100644 --- a/yarn/common/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala +++ b/yarn/common/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala @@ -113,8 +113,8 @@ private[spark] class ApplicationMaster(args: ApplicationMasterArguments, if (!unregistered) { // we only want to unregister if we don't want the RM to retry if (finalStatus == FinalApplicationStatus.SUCCEEDED || isLastAttempt) { - unregister(finalStatus, finalMsg) cleanupStagingDir() + unregister(finalStatus, finalMsg) } } }