sunhelly commented on a change in pull request #2882: URL: https://github.com/apache/hbase/pull/2882#discussion_r572552465
########## File path: hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/Compactor.java ########## @@ -345,7 +345,17 @@ private InternalScanner postCompactScannerOpen(CompactionRequestImpl request, Sc + store.getRegionInfo().getRegionNameAsString() + " because it was interrupted."); } } finally { - Closeables.close(scanner, true); + // createScanner may fail when seeking hfiles encounter Exception, e.g. even only one hfile + // reader encounters java.io.IOException: Invalid HFile block magic: \x00\x00\x00\x00\x00\x00\x00\x00 + // and then scanner will be null, but scanners for all the hfiles should be closed, + // or else we will find leak of ESTABLISHED sockets. + if (scanner == null) { + for (StoreFileScanner sfs : scanners) { + sfs.close(); + } + } else { + Closeables.close(scanner, true); Review comment: Hi, @saintstack , the PR has been updated. Function `createFileScanners` closes the store file scanners it created when encounters any exception, so it is out the try/finally. When the InternalScanner which contains all the store file scanners is not null, all the scanners will be processed when it closes. So I added a check for InternalScanner if it is null, if so, close the store file scanners manually in finally. ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org