Load: remove unnecessary flushes in writer to avoid generating bad tsfiles (#14602)

DanielWang2035 · web-flow · commit 5ebbb8da6a01 · 2025-01-02T10:25:31.000+08:00
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/LoadTsFileManager.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/LoadTsFileManager.java
@@ -435,7 +435,6 @@ private void write(DataPartitionInfo partitionInfo, ChunkData chunkData) throws
         // writers for memory control
         for (final TsFileIOWriter existingWriter : dataPartition2Writer.values()) {
           existingWriter.setMaxMetadataSize(chunkMetadataMaxSizeForEachWriter);
-          existingWriter.checkMetadataSizeAndMayFlush();
         }
         dataPartition2Writer.put(partitionInfo, writer);
         dataPartition2Resource.put(partitionInfo, resource);

Original file line number	Diff line number	Diff line change
`@@ -435,7 +435,6 @@ private void write(DataPartitionInfo partitionInfo, ChunkData chunkData) throws`
`435`	`435`	`// writers for memory control`
`436`	`436`	`for (final TsFileIOWriter existingWriter : dataPartition2Writer.values()) {`
`437`	`437`	`existingWriter.setMaxMetadataSize(chunkMetadataMaxSizeForEachWriter);`
`438`		`- existingWriter.checkMetadataSizeAndMayFlush();`
`439`	`438`	`}`
`440`	`439`	`dataPartition2Writer.put(partitionInfo, writer);`
`441`	`440`	`dataPartition2Resource.put(partitionInfo, resource);`