diff --git a/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/commit/AbstractYarnClusterITest.java b/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/commit/AbstractYarnClusterITest.java index 2501662fd4..2e8f1f0904 100644 --- a/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/commit/AbstractYarnClusterITest.java +++ b/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/commit/AbstractYarnClusterITest.java @@ -196,8 +196,9 @@ public abstract class AbstractYarnClusterITest extends AbstractCommitITest { protected Job createJob() throws IOException { - Job mrJob = Job.getInstance(getClusterBinding().getConf(), - getMethodName()); + Configuration jobConf = getClusterBinding().getConf(); + jobConf.addResource(getConfiguration()); + Job mrJob = Job.getInstance(jobConf, getMethodName()); patchConfigurationForCommitter(mrJob.getConfiguration()); return mrJob; }