This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch opt_aligned_tvlist in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit c532311b14b19d3b3b2ded5432abc2b718ea5c35 Author: HTHou <[email protected]> AuthorDate: Thu Aug 21 23:43:12 2025 +0800 deving mem_control --- .../iotdb/db/storageengine/dataregion/memtable/TsFileProcessor.java | 6 ------ 1 file changed, 6 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileProcessor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileProcessor.java index e90fc264e79..35651499b91 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileProcessor.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileProcessor.java @@ -773,7 +773,6 @@ public class TsFileProcessor { } else { // For existed device of this mem table AlignedWritableMemChunk alignedMemChunk = (AlignedWritableMemChunk) memChunk; - List<TSDataType> dataTypesInTVList = new ArrayList<>(); for (int i = 0; i < dataTypes.length; i++) { // Skip failed Measurements if (dataTypes[i] == null @@ -790,12 +789,10 @@ public class TsFileProcessor { ? 1 : 0); memTableIncrement += currentArrayNum * AlignedTVList.valueListArrayMemCost(dataTypes[i]); - dataTypesInTVList.add(dataTypes[i]); } } // this insertion will result in a new array if ((alignedMemChunk.alignedListSize() % PrimitiveArrayManager.ARRAY_SIZE) == 0) { - dataTypesInTVList.addAll(alignedMemChunk.getWorkingTVList().getTsDataTypes()); memTableIncrement += alignedMemChunk.getWorkingTVList().alignedTvListArrayMemCost(); } } @@ -1067,7 +1064,6 @@ public class TsFileProcessor { numArraysToAdd * AlignedTVList.alignedTvListArrayMemCost(dataTypes, columnCategories); } else { AlignedWritableMemChunk alignedMemChunk = (AlignedWritableMemChunk) memChunk; - List<TSDataType> dataTypesInTVList = new ArrayList<>(); int currentPointNum = alignedMemChunk.alignedListSize(); int newPointNum = currentPointNum + incomingPointNum; for (int i = 0; i < dataTypes.length; i++) { @@ -1086,7 +1082,6 @@ public class TsFileProcessor { memIncrements[0] += (currentPointNum / PrimitiveArrayManager.ARRAY_SIZE + 1) * AlignedTVList.valueListArrayMemCost(dataType); - dataTypesInTVList.add(dataType); } } @@ -1101,7 +1096,6 @@ public class TsFileProcessor { if (acquireArray != 0) { // memory of extending the TVList - dataTypesInTVList.addAll(alignedMemChunk.getWorkingTVList().getTsDataTypes()); memIncrements[0] += acquireArray * alignedMemChunk.getWorkingTVList().alignedTvListArrayMemCost(); }
