From d8f670ff28c1a9f49ef908a23850bcfddd4f46dc Mon Sep 17 00:00:00 2001 From: Sean Mackrory Date: Thu, 27 Dec 2018 08:17:52 -0700 Subject: [PATCH] HADOOP-15819. FileSystem cache misused in S3A integration tests. Contributed by Adam Antal. --- .../fs/s3a/commit/AbstractITCommitProtocol.java | 14 -------------- 1 file changed, 14 deletions(-) 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()}.