HDFS-16068. WebHdfsFileSystem has a possible connection leak in connection with HttpFS (#3104)

(cherry picked from commit 839fcf7682)
This commit is contained in:
Takanobu Asanuma 2021-06-15 16:50:09 +09:00
parent f22ff63a15
commit a690e8ae59
1 changed files with 4 additions and 2 deletions

View File

@ -2277,10 +2277,12 @@ public class WebHdfsFileSystem extends FileSystem
@VisibleForTesting
void closeInputStream(RunnerState rs) throws IOException {
if (in != null) {
IOUtils.close(cachedConnection);
in = null;
}
cachedConnection = null;
if (cachedConnection != null) {
IOUtils.close(cachedConnection);
cachedConnection = null;
}
runnerState = rs;
}