diff --git a/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/ITestS3AAWSCredentialsProvider.java b/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/ITestS3AAWSCredentialsProvider.java index 30f1f71eeea..f1805b84082 100644 --- a/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/ITestS3AAWSCredentialsProvider.java +++ b/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/ITestS3AAWSCredentialsProvider.java @@ -162,12 +162,15 @@ public class ITestS3AAWSCredentialsProvider { conf.set(AWS_CREDENTIALS_PROVIDER, AnonymousAWSCredentialsProvider.class.getName()); Path testFile = getCSVTestPath(conf); - FileSystem fs = FileSystem.newInstance(testFile.toUri(), conf); - assertNotNull(fs); - assertTrue(fs instanceof S3AFileSystem); - FileStatus stat = fs.getFileStatus(testFile); - assertNotNull(stat); - assertEquals(testFile, stat.getPath()); + try (FileSystem fs = FileSystem.newInstance(testFile.toUri(), conf)) { + assertNotNull("S3AFileSystem instance must not be null", fs); + assertTrue("FileSystem must be the instance of S3AFileSystem", fs instanceof S3AFileSystem); + FileStatus stat = fs.getFileStatus(testFile); + assertNotNull("FileStatus with qualified path must not be null", stat); + assertEquals( + "The qualified path returned by getFileStatus should be same as the original file", + testFile, stat.getPath()); + } } }