fix npe (apache#11966)

Caideyipi · Jan 24, 2024 · 092fcb5 · 092fcb5
1 parent 7f7285c
commit 092fcb5
Showing 1 changed file with 7 additions and 4 deletions.
diff --git a/...datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/node/WALNode.java b/...datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/node/WALNode.java
@@ -324,11 +324,14 @@ public void run() {
     private void updateEffectiveInfoRationAndUpdateMetric() {
       // calculate effective information ratio
       long costOfActiveMemTables = checkpointManager.getTotalCostOfActiveMemTables();
+      MemTableInfo oldestUnpinnedMemTableInfo = checkpointManager.getOldestUnpinnedMemTableInfo();
       long totalCost =
-          (getCurrentWALFileVersion()
-                  - checkpointManager.getOldestUnpinnedMemTableInfo().getFirstFileVersionId()
-                  + 1)
-              * config.getWalFileSizeThresholdInByte();
+          oldestUnpinnedMemTableInfo == null
+              ? costOfActiveMemTables
+              : (getCurrentWALFileVersion()
+                      - oldestUnpinnedMemTableInfo.getFirstFileVersionId()
+                      + 1)
+                  * config.getWalFileSizeThresholdInByte();
       if (totalCost == 0) {
         return;
       }