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);