diff --git a/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/commit/ITestS3ACommitterFactory.java b/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/commit/ITestS3ACommitterFactory.java index 78d823854d57e..2561a69f60b59 100644 --- a/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/commit/ITestS3ACommitterFactory.java +++ b/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/commit/ITestS3ACommitterFactory.java @@ -196,7 +196,8 @@ public void setup() throws Exception { maybeSetCommitterName(jobConf, jobCommitterName); tContext = new TaskAttemptContextImpl(jobConf, taskAttempt0); - LOG.info("Filesystem Committer='{}'; task='{}'", + LOG.info("{}: Filesystem Committer='{}'; task='{}'", + description, fsConf.get(FS_S3A_COMMITTER_NAME), jobConf.get(FS_S3A_COMMITTER_NAME)); } @@ -232,8 +233,7 @@ private void assertFactoryCreatesExpectedCommitter( expected, createCommitter().getClass()); } else { - intercept(PathCommitException.class, () -> - createCommitter()); + intercept(PathCommitException.class, this::createCommitter); } }