This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new c560247f8b5 Pipe: Fixed the NPE caused by new regions + history only
logic (#16879)
c560247f8b5 is described below
commit c560247f8b541d61a7d1f1302e2f20756417ee62
Author: Caideyipi <[email protected]>
AuthorDate: Mon Dec 8 14:34:52 2025 +0800
Pipe: Fixed the NPE caused by new regions + history only logic (#16879)
---
.../iotdb/confignode/procedure/impl/pipe/task/AlterPipeProcedureV2.java | 1 +
1 file changed, 1 insertion(+)
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 f6b84cb1f6e..53f908bf4fc 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
@@ -187,6 +187,7 @@ public class AlterPipeProcedureV2 extends
AbstractOperatePipeProcedureV2 {
&& !databaseName.startsWith(SchemaConstant.SYSTEM_DATABASE
+ ".")
&& !databaseName.equals(SchemaConstant.AUDIT_DATABASE)
&& !databaseName.startsWith(SchemaConstant.AUDIT_DATABASE
+ ".")
+ && !Objects.isNull(currentPipeTaskMeta)
&& !(PipeTaskAgent.isHistoryOnlyPipe(
currentPipeStaticMeta.getSourceParameters())
&& PipeTaskAgent.isHistoryOnlyPipe(
