You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ta...@apache.org on 2025/03/28 06:47:48 UTC
(iotdb) branch fix_iotv2_wal_index_set created (now 26f459b2e4b)
This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a change to branch fix_iotv2_wal_index_set
in repository https://gitbox.apache.org/repos/asf/iotdb.git
at 26f459b2e4b finish
This branch includes the following new commits:
new 26f459b2e4b finish
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(iotdb) 01/01: finish
Posted by ta...@apache.org.
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 <ta...@apache.org>
AuthorDate: Fri Mar 28 14:47:28 2025 +0800
finish
Signed-off-by: OneSizeFitQuorum <ta...@apache.org>
---
.../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 {