Repository: hadoop Updated Branches: refs/heads/trunk ff8378eb1 -> cc1085225
MAPREDUCE-7041. MR should not try to clean up at first job attempt. (Gergo Repas via Haibo Chen) Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/cc108522 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/cc108522 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/cc108522 Branch: refs/heads/trunk Commit: cc10852252c2d69294eabc68bd032cc630a53b18 Parents: ff8378e Author: Haibo Chen <haiboc...@apache.org> Authored: Thu Jan 25 16:11:01 2018 -0800 Committer: Haibo Chen <haiboc...@apache.org> Committed: Thu Jan 25 16:11:30 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/cc108522/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: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org
