(iotdb) 04/04: Pipe: Fix IO triggered in disruptor

[rong]

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

rong pushed a commit to branch fix-pipe-stuck-by-file
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit ac6dc47e8e75c8e00919b3d58583a2b122b6d2c6
Author: Steve Yurong Su <r...@apache.org>
AuthorDate: Thu Mar 13 12:52:46 2025 +0800

    Pipe: Fix IO triggered in disruptor
---
 .../iotdb/db/storageengine/dataregion/wal/utils/WALEntryHandler.java  | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/utils/WALEntryHandler.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/utils/WALEntryHandler.java
index de2379c380e..333842e38ef 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/utils/WALEntryHandler.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/utils/WALEntryHandler.java
@@ -90,9 +90,7 @@ public class WALEntryHandler {
   public InsertNode getInsertNodeViaCacheIfPossible() {
     try {
       final WALEntryValue finalValue = value;
-      return finalValue instanceof InsertNode
-          ? (InsertNode) finalValue
-          : 
walEntryPosition.readByteBufferOrInsertNodeViaCacheDirectly().getRight();
+      return finalValue instanceof InsertNode ? (InsertNode) finalValue : null;
     } catch (Exception e) {
       logger.warn("Fail to get insert node via cache. {}", this, e);
       throw e;