When the statement to execute is to drop a column, put it in the mods file instead of deleting the tsfile.

zerolbsony · zerolbsony · commit b2927fc87185 · 2026-01-11T21:07:07.000+08:00
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
@@ -3308,14 +3308,15 @@ private void deleteDataInSealedFiles(Collection<TsFileResource> sealedTsFiles, M
                   fileEndTime);
             }
             if (isFileFullyMatchedByTime(deletion, fileStartTime, fileEndTime)
-                && idPredicateType.equals(IDPredicate.IDPredicateType.NOP)) {
+                && idPredicateType.equals(IDPredicate.IDPredicateType.NOP)
+                && !isDropMeasurementExist) {
               ++matchSize;
             } else {
               deletedByMods.add(sealedTsFile);
               break;
             }
           }
-          if (matchSize == devicesInFile.size() && !isDropMeasurementExist) {
+          if (matchSize == devicesInFile.size()) {
             deletedByFiles.add(sealedTsFile);
           }
 

Original file line number	Diff line number	Diff line change
`@@ -3308,14 +3308,15 @@ private void deleteDataInSealedFiles(Collection<TsFileResource> sealedTsFiles, M`
`3308`	`3308`	`fileEndTime);`
`3309`	`3309`	`}`
`3310`	`3310`	`if (isFileFullyMatchedByTime(deletion, fileStartTime, fileEndTime)`
`3311`		`- && idPredicateType.equals(IDPredicate.IDPredicateType.NOP)) {`
	`3311`	`+ && idPredicateType.equals(IDPredicate.IDPredicateType.NOP)`
	`3312`	`+ && !isDropMeasurementExist) {`
`3312`	`3313`	`++matchSize;`
`3313`	`3314`	`} else {`
`3314`	`3315`	`deletedByMods.add(sealedTsFile);`
`3315`	`3316`	`break;`
`3316`	`3317`	`}`
`3317`	`3318`	`}`
`3318`		`- if (matchSize == devicesInFile.size() && !isDropMeasurementExist) {`
	`3319`	`+ if (matchSize == devicesInFile.size()) {`
`3319`	`3320`	`deletedByFiles.add(sealedTsFile);`
`3320`	`3321`	`}`
`3321`	`3322`