Skip to content

Commit 7e923c5

Browse files
author
vnarayanan
committed
Formatting
1 parent 92624bb commit 7e923c5

File tree

4 files changed

+7
-3
lines changed

4 files changed

+7
-3
lines changed

hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/commit/AbstractS3ACommitter.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -252,8 +252,8 @@ protected AbstractS3ACommitter(
252252
* @throws IOException on a failure
253253
*/
254254
protected AbstractS3ACommitter(
255-
Path outputPath,
256-
JobContext context) throws IOException {
255+
Path outputPath,
256+
JobContext context) throws IOException {
257257
super(outputPath, context);
258258
setOutputPath(outputPath);
259259
this.jobContext = requireNonNull(context, "null job context");

hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/commit/AbstractS3ACommitterFactory.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -58,6 +58,7 @@ public PathOutputCommitter createOutputCommitter(Path outputPath,
5858
return outputCommitter;
5959
}
6060

61+
@Override
6162
public PathOutputCommitter createOutputCommitter(Path outputPath,
6263
JobContext context) throws IOException {
6364
FileSystem fs = getDestinationFileSystem(outputPath, context);

hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/commit/magic/MagicS3GuardCommitter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -92,7 +92,7 @@ public MagicS3GuardCommitter(Path outputPath,
9292
* @throws IOException on a failure
9393
*/
9494
public MagicS3GuardCommitter(Path outputPath,
95-
JobContext context) throws IOException {
95+
JobContext context) throws IOException {
9696
super(outputPath, context);
9797
setWorkPath(getJobAttemptPath(context));
9898
verifyIsMagicCommitPath(getDestS3AFS(), getWorkPath());

hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/commit/magic/mapred/MagicS3GuardCommitter.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,9 @@
2727

2828
import java.io.IOException;
2929

30+
/**
31+
* This is a mapred wrapper for the MagicS3GuardCommitter.
32+
*/
3033
public class MagicS3GuardCommitter extends OutputCommitter {
3134

3235
private org.apache.hadoop.fs.s3a.commit.magic.MagicS3GuardCommitter committer = null;

0 commit comments

Comments
 (0)