(iotdb) branch object_type updated: fix WALEntryHandler oom

[haonan]

This is an automated email from the ASF dual-hosted git repository.

haonan pushed a commit to branch object_type
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/object_type by this push:
     new dfb0a5f06be fix WALEntryHandler oom
dfb0a5f06be is described below

commit dfb0a5f06bee801850be6943fba2a375ee86cb97
Author: HTHou <hao...@apache.org>
AuthorDate: Thu Jul 10 16:59:39 2025 +0800

    fix WALEntryHandler oom
---
 .../db/storageengine/dataregion/wal/buffer/WALEntry.java     | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/buffer/WALEntry.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/buffer/WALEntry.java
index f91e6b64265..059d363f539 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/buffer/WALEntry.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/buffer/WALEntry.java
@@ -83,14 +83,22 @@ public abstract class WALEntry implements SerializedSize {
     } else {
       throw new RuntimeException("Unknown WALEntry type");
     }
-    walFlushListener = new WALFlushListener(wait, value);
+    if (type == WALEntryType.OBJECT_FILE_NODE) {
+      this.walFlushListener = new WALFlushListener(wait, null);
+    } else {
+      this.walFlushListener = new WALFlushListener(wait, value);
+    }
   }
 
   protected WALEntry(WALEntryType type, long memTableId, WALEntryValue value, 
boolean wait) {
     this.type = type;
     this.memTableId = memTableId;
     this.value = value;
-    this.walFlushListener = new WALFlushListener(wait, value);
+    if (type == WALEntryType.OBJECT_FILE_NODE) {
+      this.walFlushListener = new WALFlushListener(wait, null);
+    } else {
+      this.walFlushListener = new WALFlushListener(wait, value);
+    }
   }
 
   public abstract void serialize(IWALByteBufferView buffer);