(paimon) branch master updated: [avro] Adjust do not flush on every block for DataFileWriter

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 5e99416c0 [avro] Adjust do not flush on every block for DataFileWriter
5e99416c0 is described below

commit 5e99416c05c3cafb269eabaa8e2fd48474e39927
Author: Jingsong <jingsongl...@gmail.com>
AuthorDate: Mon Aug 5 11:49:05 2024 +0800

    [avro] Adjust do not flush on every block for DataFileWriter
---
 .../src/main/java/org/apache/paimon/format/avro/AvroFileFormat.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/paimon-format/src/main/java/org/apache/paimon/format/avro/AvroFileFormat.java 
b/paimon-format/src/main/java/org/apache/paimon/format/avro/AvroFileFormat.java
index 0a9f5e092..b8a27b749 100644
--- 
a/paimon-format/src/main/java/org/apache/paimon/format/avro/AvroFileFormat.java
+++ 
b/paimon-format/src/main/java/org/apache/paimon/format/avro/AvroFileFormat.java
@@ -123,8 +123,8 @@ public class AvroFileFormat extends FileFormat {
                                 DataFileWriter<InternalRow> dataFileWriter =
                                         new DataFileWriter<>(datumWriter);
                                 
dataFileWriter.setCodec(createCodecFactory(compression));
-                                dataFileWriter.create(schema, out);
                                 dataFileWriter.setFlushOnEveryBlock(false);
+                                dataFileWriter.create(schema, out);
                                 return dataFileWriter;
                             });
         }