(iotdb) branch master updated: fix: resolve cannot find symbol error in CreatePipe #16951

[jackietien]

This is an automated email from the ASF dual-hosted git repository.

jackietien 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 8e99486f6cd fix: resolve cannot find symbol error in CreatePipe #16951
8e99486f6cd is described below

commit 8e99486f6cd669383d5cf749b2ca2e54bd06bd40
Author: Le Yang <562593...@qq.com>
AuthorDate: Thu Dec 25 15:01:56 2025 +0800

    fix: resolve cannot find symbol error in CreatePipe #16951
---
 .../iotdb/db/queryengine/plan/relational/sql/ast/CreatePipe.java      | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/CreatePipe.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/CreatePipe.java
index 1543e339fc8..269978e87bd 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/CreatePipe.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/CreatePipe.java
@@ -115,9 +115,9 @@ public class CreatePipe extends PipeStatement {
     long size = INSTANCE_SIZE;
     size += 
AstMemoryEstimationHelper.getEstimatedSizeOfNodeLocation(getLocationInternal());
     size += RamUsageEstimator.sizeOf(pipeName);
-    size += RamUsageEstimator.sizeOfMap(extractorAttributes);
+    size += RamUsageEstimator.sizeOfMap(sourceAttributes);
     size += RamUsageEstimator.sizeOfMap(processorAttributes);
-    size += RamUsageEstimator.sizeOfMap(connectorAttributes);
+    size += RamUsageEstimator.sizeOfMap(sinkAttributes);
     return size;
   }
 }