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 <[email protected]> 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(
