From c0a0c353e86fc3f3d4eedd91aeb9d5b9c8eb748a Mon Sep 17 00:00:00 2001 From: Mehul Garnara Date: Mon, 2 Oct 2017 13:00:36 -0400 Subject: [PATCH] MAPREDUCE-6973. Fix comments on creating _SUCCESS file. This closes #280 Signed-off-by: Akira Ajisaka --- .../hadoop/mapreduce/lib/output/FileOutputCommitter.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/FileOutputCommitter.java b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/FileOutputCommitter.java index 94af3387d7..7f1ea6175e 100644 --- a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/FileOutputCommitter.java +++ b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/output/FileOutputCommitter.java @@ -409,7 +409,7 @@ protected void commitJobInternal(JobContext context) throws IOException { LOG.info("Skip cleanup the _temporary folders under job's output " + "directory in commitJob."); } else { - // delete the _temporary folder and create a _done file in the o/p + // delete the _temporary folder and create a _SUCCESS file in the o/p // folder try { cleanupJob(context); @@ -426,6 +426,7 @@ protected void commitJobInternal(JobContext context) throws IOException { } // True if the job requires output.dir marked on successful job. // Note that by default it is set to true. + // Create a _SUCCESS file in the o/p folder. if (context.getConfiguration().getBoolean( SUCCESSFUL_JOB_OUTPUT_DIR_MARKER, true)) { Path markerPath = new Path(outputPath, SUCCEEDED_FILE_NAME);