diff --git a/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/commit/AbstractITCommitProtocol.java b/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/commit/AbstractITCommitProtocol.java index 5ae8f54522..e560e112c1 100644 --- a/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/commit/AbstractITCommitProtocol.java +++ b/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/commit/AbstractITCommitProtocol.java @@ -153,8 +153,6 @@ public void setup() throws Exception { taskAttempt1 = TaskAttemptID.forName(attempt1); outDir = path(getMethodName()); - S3AFileSystem fileSystem = getFileSystem(); - bindFileSystem(fileSystem, outDir, fileSystem.getConf()); abortMultipartUploadsUnderPath(outDir); cleanupDestDir(); } @@ -196,18 +194,6 @@ protected Configuration createConfiguration() { return conf; } - /** - * Bind a path to the FS in the cache. - * @param fs filesystem - * @param path s3 path - * @param conf configuration - * @throws IOException any problem - */ - private void bindFileSystem(FileSystem fs, Path path, Configuration conf) - throws IOException { - FileSystemTestHelper.addFileSystemForTesting(path.toUri(), conf, fs); - } - /*** * Bind to the committer from the methods of * {@link #getCommitterFactoryName()} and {@link #getCommitterName()}.