(iotdb) branch feature/memory_auto updated: Fix Symbol

[spricoder]

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

spricoder pushed a commit to branch feature/memory_auto
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/feature/memory_auto by this 
push:
     new 24770b9d463 Fix Symbol
24770b9d463 is described below

commit 24770b9d46379442daefe9450925a84665a24127
Author: spricoder <sprico...@qq.com>
AuthorDate: Thu Feb 27 14:05:33 2025 +0800

    Fix Symbol
---
 .../java/org/apache/iotdb/db/consensus/DataRegionConsensusImpl.java    | 3 ++-
 .../iotdb/db/storageengine/rescon/memory/TimePartitionManagerTest.java | 1 +
 2 files changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/consensus/DataRegionConsensusImpl.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/consensus/DataRegionConsensusImpl.java
index 56d9ee7b052..b71b285e88a 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/consensus/DataRegionConsensusImpl.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/consensus/DataRegionConsensusImpl.java
@@ -43,6 +43,7 @@ import 
org.apache.iotdb.db.consensus.statemachine.dataregion.IoTConsensusDataReg
 import org.apache.iotdb.db.pipe.agent.PipeDataNodeAgent;
 import org.apache.iotdb.db.pipe.consensus.ConsensusPipeDataNodeDispatcher;
 import 
org.apache.iotdb.db.pipe.consensus.ConsensusPipeDataNodeRuntimeAgentGuardian;
+import org.apache.iotdb.db.pipe.consensus.ReplicateProgressDataNodeManager;
 import org.apache.iotdb.db.pipe.consensus.deletion.DeletionResourceManager;
 import org.apache.iotdb.db.storageengine.StorageEngine;
 import org.apache.iotdb.db.storageengine.dataregion.DataRegion;
@@ -177,7 +178,7 @@ public class DataRegionConsensusImpl {
                           .setConsensusPipeSelector(
                               () -> 
PipeDataNodeAgent.task().getAllConsensusPipe())
                           
.setConsensusPipeReceiver(PipeDataNodeAgent.receiver().pipeConsensus())
-                          .setProgressIndexManager(new 
ProgressIndexDataNodeManager())
+                          .setProgressIndexManager(new 
ReplicateProgressDataNodeManager())
                           .setConsensusPipeGuardJobIntervalInSeconds(300)
                           .build())
                   
.setReplicateMode(ReplicateMode.fromValue(CONF.getIotConsensusV2Mode()))
diff --git 
a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/rescon/memory/TimePartitionManagerTest.java
 
b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/rescon/memory/TimePartitionManagerTest.java
index ed479640978..2c77b82500d 100644
--- 
a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/rescon/memory/TimePartitionManagerTest.java
+++ 
b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/rescon/memory/TimePartitionManagerTest.java
@@ -26,6 +26,7 @@ import org.apache.iotdb.db.conf.IoTDBConfig;
 import org.apache.iotdb.db.conf.IoTDBDescriptor;
 import org.apache.iotdb.db.exception.StorageEngineException;
 import org.apache.iotdb.db.exception.query.QueryProcessException;
+
 import org.apache.tsfile.exception.write.WriteProcessException;
 import org.junit.After;
 import org.junit.Assert;