This is an automated email from the ASF dual-hosted git repository. caogaofei pushed a commit to branch last_cache in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 621239cf590cf9bd643447da10dfbb36e8c647fd Author: Beyyes <[email protected]> AuthorDate: Fri Oct 25 16:27:36 2024 +0800 add maxPeekMemory --- .../source/relational/TableAggregationTableScanOperator.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/TableAggregationTableScanOperator.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/TableAggregationTableScanOperator.java index fe086fd9e13..34e8f4ecd1f 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/TableAggregationTableScanOperator.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/TableAggregationTableScanOperator.java @@ -846,18 +846,19 @@ public class TableAggregationTableScanOperator extends AbstractDataSourceOperato + MemoryEstimationHelper.getEstimatedSizeOfAccountableObject(seriesScanUtil) + MemoryEstimationHelper.getEstimatedSizeOfAccountableObject(operatorContext) + MemoryEstimationHelper.getEstimatedSizeOfAccountableObject(sourceId) + + tableAggregators.stream().mapToLong(TableAggregator::getEstimatedSize).sum() + (resultTsBlockBuilder == null ? 0 : resultTsBlockBuilder.getRetainedSizeInBytes()) + RamUsageEstimator.sizeOfCollection(deviceEntries); } @Override public long calculateMaxPeekMemory() { - return 0; + return cachedRawDataSize + maxReturnSize; } @Override public long calculateMaxReturnSize() { - return 0; + return maxReturnSize; } @Override
