Repository: hadoop Updated Branches: refs/heads/branch-3.0 217f408aa -> e6c66baba
MAPREDUCE-7041. MR should not try to clean up at first job attempt. (Gergo Repas via Haibo Chen) (cherry picked from commit cc10852252c2d69294eabc68bd032cc630a53b18) Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/e6c66bab Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/e6c66bab Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/e6c66bab Branch: refs/heads/branch-3.0 Commit: e6c66baba97c34514e1d7491d5fe80867930f184 Parents: 217f408 Author: Haibo Chen <[email protected]> Authored: Thu Jan 25 16:11:01 2018 -0800 Committer: Haibo Chen <[email protected]> Committed: Thu Jan 25 17:14:25 2018 -0800 ---------------------------------------------------------------------- .../main/java/org/apache/hadoop/mapreduce/v2/app/MRAppMaster.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/e6c66bab/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/MRAppMaster.java ---------------------------------------------------------------------- diff --git a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/MRAppMaster.java b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/MRAppMaster.java index e6a45cf..cb65b89 100644 --- a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/MRAppMaster.java +++ b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/MRAppMaster.java @@ -1400,7 +1400,7 @@ public class MRAppMaster extends CompositeService { private void cleanUpPreviousJobOutput() { // recovered application masters should not remove data from previous job - if (!recovered()) { + if (!isFirstAttempt() && !recovered()) { JobContext jobContext = getJobContextFromConf(getConfig()); try { LOG.info("Starting to clean up previous job's temporary files"); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
