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

DanielWang2035 · web-flow · commit 78b29c03fc1d · 2025-01-02T15:51:44.000+08:00
(cherry picked from commit 5ebbb8d)
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
@@ -426,7 +426,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
`@@ -426,7 +426,6 @@ private void write(DataPartitionInfo partitionInfo, ChunkData chunkData) throws`
`426`	`426`	`// writers for memory control`
`427`	`427`	`for (final TsFileIOWriter existingWriter : dataPartition2Writer.values()) {`
`428`	`428`	`existingWriter.setMaxMetadataSize(chunkMetadataMaxSizeForEachWriter);`
`429`		`- existingWriter.checkMetadataSizeAndMayFlush();`
`430`	`429`	`}`
`431`	`430`	`dataPartition2Writer.put(partitionInfo, writer);`
`432`	`431`	`dataPartition2Resource.put(partitionInfo, resource);`