diff --git a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/ChecksumFileSystem.java b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/ChecksumFileSystem.java index 46a235af5e7..e2f078004f9 100644 --- a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/ChecksumFileSystem.java +++ b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/ChecksumFileSystem.java @@ -197,7 +197,6 @@ public int read(long position, byte[] b, int off, int len) new ChecksumFSInputChecker(fs, file)) { checker.seek(position); nread = checker.read(b, off, len); - checker.close(); } return nread; } diff --git a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/ChecksumFs.java b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/ChecksumFs.java index e5cecf65c54..a326adb38fa 100644 --- a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/ChecksumFs.java +++ b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/ChecksumFs.java @@ -179,7 +179,6 @@ public int read(long position, byte[] b, int off, int len) new ChecksumFSInputChecker(fs, file)) { checker.seek(position); nread = checker.read(b, off, len); - checker.close(); } return nread; }