fix: resolve cannot find symbol error in CreatePipe #16951

Young-Leo · web-flow · commit 8e99486f6cd6 · 2025-12-25T15:01:56.000+08:00
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
@@ -115,9 +115,9 @@ public long ramBytesUsed() {
     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;
   }
 }

Original file line number	Diff line number	Diff line change
`@@ -115,9 +115,9 @@ public long ramBytesUsed() {`
`115`	`115`	`long size = INSTANCE_SIZE;`
`116`	`116`	`size += AstMemoryEstimationHelper.getEstimatedSizeOfNodeLocation(getLocationInternal());`
`117`	`117`	`size += RamUsageEstimator.sizeOf(pipeName);`
`118`		`- size += RamUsageEstimator.sizeOfMap(extractorAttributes);`
	`118`	`+ size += RamUsageEstimator.sizeOfMap(sourceAttributes);`
`119`	`119`	`size += RamUsageEstimator.sizeOfMap(processorAttributes);`
`120`		`- size += RamUsageEstimator.sizeOfMap(connectorAttributes);`
	`120`	`+ size += RamUsageEstimator.sizeOfMap(sinkAttributes);`
`121`	`121`	`return size;`
`122`	`122`	`}`
`123`	`123`	`}`