(paimon) branch master updated: [arrow] Allocate buffer for MapVector in init (#4347)

[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 fee0dc1e4 [arrow] Allocate buffer for MapVector in init (#4347)
fee0dc1e4 is described below

commit fee0dc1e41195e257f360527d3e228991e1ce927
Author: YeJunHao <41894543+leaves12...@users.noreply.github.com>
AuthorDate: Mon Oct 21 23:24:42 2024 +0800

    [arrow] Allocate buffer for MapVector in init (#4347)
---
 .../org/apache/paimon/arrow/writer/ArrowFieldWriterFactoryVisitor.java   | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/paimon-arrow/src/main/java/org/apache/paimon/arrow/writer/ArrowFieldWriterFactoryVisitor.java
 
b/paimon-arrow/src/main/java/org/apache/paimon/arrow/writer/ArrowFieldWriterFactoryVisitor.java
index 9c1a55ec3..eef53009c 100644
--- 
a/paimon-arrow/src/main/java/org/apache/paimon/arrow/writer/ArrowFieldWriterFactoryVisitor.java
+++ 
b/paimon-arrow/src/main/java/org/apache/paimon/arrow/writer/ArrowFieldWriterFactoryVisitor.java
@@ -158,6 +158,7 @@ public class ArrowFieldWriterFactoryVisitor implements 
DataTypeVisitor<ArrowFiel
         ArrowFieldWriterFactory valueWriterFactory = 
mapType.getValueType().accept(this);
         return fieldVector -> {
             MapVector mapVector = (MapVector) fieldVector;
+            mapVector.reAlloc();
             List<FieldVector> keyValueVectors = 
mapVector.getDataVector().getChildrenFromFields();
             return new ArrowFieldWriters.MapWriter(
                     fieldVector,