Skip to content

Commit c560247

Browse files
authored
Pipe: Fixed the NPE caused by new regions + history only logic (apache#16879)
1 parent 0bb9e96 commit c560247

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/AlterPipeProcedureV2.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -187,6 +187,7 @@ public void executeFromCalculateInfoForTask(final ConfigNodeProcedureEnv env) {
187187
&& !databaseName.startsWith(SchemaConstant.SYSTEM_DATABASE + ".")
188188
&& !databaseName.equals(SchemaConstant.AUDIT_DATABASE)
189189
&& !databaseName.startsWith(SchemaConstant.AUDIT_DATABASE + ".")
190+
&& !Objects.isNull(currentPipeTaskMeta)
190191
&& !(PipeTaskAgent.isHistoryOnlyPipe(
191192
currentPipeStaticMeta.getSourceParameters())
192193
&& PipeTaskAgent.isHistoryOnlyPipe(

0 commit comments

Comments
 (0)