Skip to content

Commit 2b69da1

Browse files
committed
fix tests
1 parent 32ed833 commit 2b69da1

File tree

1 file changed

+2
-17
lines changed

1 file changed

+2
-17
lines changed

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/AlignedWritableMemChunk.java

Lines changed: 2 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,6 @@
5050
import java.nio.ByteBuffer;
5151
import java.util.ArrayList;
5252
import java.util.Arrays;
53-
import java.util.HashMap;
5453
import java.util.LinkedHashMap;
5554
import java.util.List;
5655
import java.util.Map;
@@ -435,22 +434,8 @@ public void removeColumn(String measurementId) {
435434
for (AlignedTVList alignedTvList : sortedList) {
436435
alignedTvList.deleteColumn(columnIndex);
437436
}
438-
// notice: the mem chunk and TVList shares data type list,
439-
// and list.deleteColumn will modify it. Therefore, do not modify it here again.
440-
schemaList.remove(columnIndex);
441-
measurementIndexMap.remove(measurementId);
442-
if (columnIndex != measurementIndexMap.size()) {
443-
Map<String, Integer> newIndexMap = new HashMap<>();
444-
measurementIndexMap.forEach(
445-
(k, v) -> {
446-
if (v > columnIndex) {
447-
newIndexMap.put(k, v - 1);
448-
} else {
449-
newIndexMap.put(k, v);
450-
}
451-
});
452-
measurementIndexMap = newIndexMap;
453-
}
437+
IMeasurementSchema schemaToBeRemoved = schemaList.get(columnIndex);
438+
measurementIndexMap.remove(schemaToBeRemoved.getMeasurementName());
454439
}
455440

456441
@Override

0 commit comments

Comments
 (0)