This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a commit to branch index-fix
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/index-fix by this push:
new e43acae49ec try-fix-index
e43acae49ec is described below
commit e43acae49ec8ac6d10f6b5424514f77a90519929
Author: Caideyipi <[email protected]>
AuthorDate: Thu Feb 26 16:57:17 2026 +0800
try-fix-index
---
.../confignode/procedure/impl/pipe/task/AlterPipeProcedureV2.java | 8 +++++++-
1 file changed, 7 insertions(+), 1 deletion(-)
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/AlterPipeProcedureV2.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/AlterPipeProcedureV2.java
index 7b74b9dddc5..bf36ef96004 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/AlterPipeProcedureV2.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/AlterPipeProcedureV2.java
@@ -21,6 +21,7 @@ package org.apache.iotdb.confignode.procedure.impl.pipe.task;
import org.apache.iotdb.common.rpc.thrift.TConsensusGroupType;
import org.apache.iotdb.common.rpc.thrift.TSStatus;
+import org.apache.iotdb.commons.consensus.index.impl.MinimumProgressIndex;
import org.apache.iotdb.commons.pipe.agent.task.PipeTaskAgent;
import org.apache.iotdb.commons.pipe.agent.task.meta.PipeMeta;
import org.apache.iotdb.commons.pipe.agent.task.meta.PipeRuntimeMeta;
@@ -209,7 +210,12 @@ public class AlterPipeProcedureV2 extends
AbstractOperatePipeProcedureV2 {
updatedConsensusGroupIdToTaskMetaMap.put(
regionGroupId.getId(),
new PipeTaskMeta(
- currentPipeTaskMeta.getProgressIndex(),
+ PipeTaskAgent.isRealtimeOnlyPipe(
+
currentPipeStaticMeta.getSourceParameters())
+ && PipeTaskAgent.isHistoryOnlyPipe(
+
updatedPipeStaticMeta.getSourceParameters())
+ ? currentPipeTaskMeta.getProgressIndex()
+ : MinimumProgressIndex.INSTANCE,
PipeTaskMeta.isNewlyAdded(currentPipeTaskMeta.getLeaderNodeId())
&& !(!PipeTaskAgent.isHistoryOnlyPipe(
currentPipeStaticMeta.getSourceParameters())
