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();
       }

Reply via email to