From 0cfc8cebb14922edb67607ee900cd17b96b107a1 Mon Sep 17 00:00:00 2001 From: Tian Jiang Date: Wed, 8 Jul 2026 10:16:34 +0800 Subject: [PATCH] Fix that ProgressWALIterator may read incorrect searchIndex --- .../db/subscription/broker/consensus/ProgressWALIterator.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/consensus/ProgressWALIterator.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/consensus/ProgressWALIterator.java index 359715d9467c2..8fd23042ea9a0 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/consensus/ProgressWALIterator.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/consensus/ProgressWALIterator.java @@ -24,6 +24,7 @@ import org.apache.iotdb.consensus.common.request.IndexedConsensusRequest; import org.apache.iotdb.consensus.common.request.IoTConsensusRequest; import org.apache.iotdb.db.i18n.DataNodePipeMessages; +import org.apache.iotdb.db.queryengine.plan.planner.plan.node.write.SearchNode; import org.apache.iotdb.db.storageengine.dataregion.wal.buffer.WALEntryType; import org.apache.iotdb.db.storageengine.dataregion.wal.buffer.WALInfoEntry; import org.apache.iotdb.db.storageengine.dataregion.wal.io.ProgressWALReader; @@ -461,7 +462,7 @@ private long getSearchIndexOrMetadataFallback( return metadataSearchIndex; } buffer.position(SEARCH_INDEX_OFFSET); - final long bodySearchIndex = buffer.getLong(); + final long bodySearchIndex = SearchNode.extractSearchIndex(buffer.getLong()); return bodySearchIndex >= 0 ? bodySearchIndex : metadataSearchIndex; }