This is an automated email from the ASF dual-hosted git repository.
jark pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git
from 920809f80 [flink] Flink Source need to check tableId on recovery in
case that table is recreated. (#2154)
new 8fd792bde [common] Fix IndexOutOfBoundsException in ArrowArrayWriter
when element count exceeds INITIAL_CAPACITY (#2165)
new 7fad656f1 [common Improve ArrowArrayWriter performance by replacing
hardcoded handleSafe=true with dynamic check based on fieldIndex
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../org/apache/fluss/row/arrow/ArrowWriter.java | 5 +-
.../fluss/row/arrow/writers/ArrowArrayWriter.java | 8 ++-
.../fluss/row/arrow/ArrowReaderWriterTest.java | 66 ++++++++++++++++++++++
3 files changed, 77 insertions(+), 2 deletions(-)
