You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2025/12/11 03:19:06 UTC
(iotdb) 01/13: Pipe: Fixed the NPE caused by new regions + history only logic (#16879)
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch force_ci/object_type
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 55abd0d1a9e7f6e5c113e5783f9899162a9ecc17
Author: Caideyipi <87...@users.noreply.github.com>
AuthorDate: Mon Dec 8 14:34:52 2025 +0800
Pipe: Fixed the NPE caused by new regions + history only logic (#16879)
(cherry picked from commit c560247f8b541d61a7d1f1302e2f20756417ee62)
---
.../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(