This is an automated email from the ASF dual-hosted git repository. tanxinyu pushed a commit to branch fix_iotv2_wal_index_set in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 26f459b2e4b371fd81a0965d8c15eb58ff74536a Author: OneSizeFitQuorum <[email protected]> AuthorDate: Fri Mar 28 14:47:28 2025 +0800 finish Signed-off-by: OneSizeFitQuorum <[email protected]> --- .../iotdb/db/storageengine/dataregion/DataRegion.java | 13 ++++++++----- 1 file changed, 8 insertions(+), 5 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java index a2e6873360b..c0bb69a1823 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java @@ -118,6 +118,7 @@ import org.apache.iotdb.db.storageengine.dataregion.utils.fileTimeIndexCache.Fil import org.apache.iotdb.db.storageengine.dataregion.utils.validate.TsFileValidator; import org.apache.iotdb.db.storageengine.dataregion.wal.WALManager; import org.apache.iotdb.db.storageengine.dataregion.wal.node.IWALNode; +import org.apache.iotdb.db.storageengine.dataregion.wal.node.WALNode; import org.apache.iotdb.db.storageengine.dataregion.wal.recover.WALRecoverManager; import org.apache.iotdb.db.storageengine.dataregion.wal.recover.file.SealedTsFileRecoverPerformer; import org.apache.iotdb.db.storageengine.dataregion.wal.recover.file.UnsealedTsFileRecoverPerformer; @@ -660,11 +661,13 @@ public class DataRegion implements IDataRegionForQuery { } if (StorageEngine.getInstance().isReadyForReadAndWrite()) { - if (config.getDataRegionConsensusProtocolClass().equals(ConsensusFactory.IOT_CONSENSUS) - || config - .getDataRegionConsensusProtocolClass() - .equals(ConsensusFactory.IOT_CONSENSUS_V2)) { - WALManager.getInstance().applyForWALNode(databaseName + FILE_NAME_SEPARATOR + dataRegionId); + if (config.getDataRegionConsensusProtocolClass().equals(ConsensusFactory.IOT_CONSENSUS_V2)) { + IWALNode walNode = + WALManager.getInstance() + .applyForWALNode(databaseName + FILE_NAME_SEPARATOR + dataRegionId); + if (walNode instanceof WALNode) { + walNode.setSafelyDeletedSearchIndex(Long.MAX_VALUE); + } } logger.info("The data region {}[{}] is created successfully", databaseName, dataRegionId); } else {
