You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@paimon.apache.org by lz...@apache.org on 2024/08/05 03:49:17 UTC
(paimon) branch master updated: [avro] Adjust do not flush on every block for DataFileWriter
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 <ji...@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;
});
}