|
@@ -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()}.
|