diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HStore.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HStore.java index 8bdc070..1da8e55 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HStore.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HStore.java @@ -1706,12 +1706,21 @@ public class HStore implements Store, HeapSize, StoreConfigInformation, Propagat // Reloading the store files from file system due to HBASE-20940. As split can happen with an // region which has references reloadedStoreFiles = loadStoreFiles(); - return StoreUtils.hasReferences(reloadedStoreFiles); } catch (IOException ioe) { LOG.error("Error trying to determine if store has references, assuming references exists", ioe); return true; } + try { + return StoreUtils.hasReferences(reloadedStoreFiles); + } finally { + for (HStoreFile storeFile : reloadedStoreFiles) { + try { + storeFile.closeStoreFile(false); + } catch (IOException ioe) { + } + } + } } /**