Repository: hadoop Updated Branches: refs/heads/trunk dea2c1b48 -> d8f670ff2
HADOOP-15819. FileSystem cache misused in S3A integration tests. Contributed by Adam Antal. Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/d8f670ff Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/d8f670ff Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/d8f670ff Branch: refs/heads/trunk Commit: d8f670ff28c1a9f49ef908a23850bcfddd4f46dc Parents: dea2c1b Author: Sean Mackrory <[email protected]> Authored: Thu Dec 27 08:17:52 2018 -0700 Committer: Sean Mackrory <[email protected]> Committed: Thu Dec 27 08:19:25 2018 -0700 ---------------------------------------------------------------------- .../fs/s3a/commit/AbstractITCommitProtocol.java | 14 -------------- 1 file changed, 14 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/d8f670ff/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/commit/AbstractITCommitProtocol.java ---------------------------------------------------------------------- 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 5ae8f54..e560e11 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 abstract class AbstractITCommitProtocol extends AbstractCommitITest { taskAttempt1 = TaskAttemptID.forName(attempt1); outDir = path(getMethodName()); - S3AFileSystem fileSystem = getFileSystem(); - bindFileSystem(fileSystem, outDir, fileSystem.getConf()); abortMultipartUploadsUnderPath(outDir); cleanupDestDir(); } @@ -196,18 +194,6 @@ public abstract class AbstractITCommitProtocol extends AbstractCommitITest { 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()}. --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
