Frank Wong created FLINK-38432:
----------------------------------
Summary: Missing finish/reset for keyWriter/valueWriter in
ArrowMapWriter
Key: FLINK-38432
URL: https://issues.apache.org/jira/browse/FLINK-38432
Project: Flink
Issue Type: Bug
Reporter: Frank Wong
The _finish_ and _reset_ methods in
_org.apache.flink.table.runtime.arrow.writers.MapWriter_ should be implemented
in the same way as in
{_}org.apache.flink.table.runtime.arrow.writers.RowWriter{_}.
Otherwise, the following sequence will lead to incorrect behavior:
{code:java}
MapWriter.write
// Arrow data is right
MapWriter.finish
MapWriter.reset
MapWriter.write
// Arrow data is wrong, map is null
MapWriter.finish
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
