HBASE-23590 : Update maxCompactedStoreFileRef (ADDENDUM)

apache · Jan 2, 2020 · 19b35d2 · 19b35d2
1 parent e0c419d
commit 19b35d2
Showing 1 changed file with 9 additions and 6 deletions.
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
@@ -2878,12 +2878,15 @@ public int getStoreRefCount() {
    */
   public int getMaxCompactedStoreFileRefCount() {
     int maxCompactedStoreFileRefCount = 0;
-    for (StoreFile store : storeEngine.getStoreFileManager().getCompactedfiles()) {
-      if (store.isHFile()) {
-        StoreFile.Reader storeReader = store.getReader();
-        if (storeReader != null) {
-          maxCompactedStoreFileRefCount = Math.max(maxCompactedStoreFileRefCount,
-            storeReader.getRefCount());
+    Collection<StoreFile> compactedFiles = storeEngine.getStoreFileManager().getCompactedfiles();
+    if (compactedFiles != null) {
+      for (StoreFile store : compactedFiles) {
+        if (store.isHFile()) {
+          StoreFile.Reader storeReader = store.getReader();
+          if (storeReader != null) {
+            maxCompactedStoreFileRefCount = Math.max(maxCompactedStoreFileRefCount,
+              storeReader.getRefCount());
+          }
         }
       }
     }