(fluss) branch main updated (07721fe6e -> f1a75ca0a)

[ja...@apache.org]

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 07721fe6e [server][client] Improve the design and performance of ADD COLUMN operation
     add fe7d0cb31 [flink] Support Array type in Flink connector (#2040)
     add eb8736bab [server][flink] Validate array type in server side and add more array type Flink IT cases (#2040)
     add f1a75ca0a [common] Deep copy ColumnarArray in CompletedFetch#fetchRecords() to fix Arrow IndexOutOfBoundsException (#2040)

No new revisions were added by this update.

Summary of changes:
 .../scanner/log/DefaultCompletedFetchTest.java     |  83 ++++++
 .../apache/fluss/record/DefaultLogRecordBatch.java |   2 +-
 .../apache/fluss/record/LogRecordReadContext.java  |   3 +-
 .../java/org/apache/fluss/row/GenericArray.java    |  47 ++--
 .../java/org/apache/fluss/row/InternalArray.java   |  51 ++++
 .../java/org/apache/fluss/row/InternalRow.java     |  55 ++++
 .../org/apache/fluss/row/arrow/ArrowReader.java    |  15 +-
 .../org/apache/fluss/row/arrow/ArrowWriter.java    |  20 +-
 .../fluss/row/arrow/writers/ArrowArrayWriter.java  |   8 +
 .../fluss/row/arrow/writers/ArrowFieldWriter.java  |   5 +
 .../java/org/apache/fluss/utils/ArrowUtils.java    |   3 +-
 .../fluss/row/arrow/ArrowReaderWriterTest.java     |   1 -
 .../org/apache/fluss/testutils/DataTestUtils.java  |  28 +-
 ...kITCase.java => Flink118ComplexTypeITCase.java} |   4 +-
 .../flink/sink/Flink119ComplexTypeITCase.java}     |   4 +-
 .../flink/sink/Flink120ComplexTypeITCase.java}     |   4 +-
 .../flink/sink/Flink21ComplexTypeITCase.java}      |   4 +-
 .../fluss/flink/sink/FlinkComplexTypeITCase.java   | 310 +++++++++++++++++++++
 .../server/utils/TableDescriptorValidation.java    |  41 ++-
 19 files changed, 632 insertions(+), 56 deletions(-)
 copy fluss-flink/fluss-flink-1.18/src/test/java/org/apache/fluss/flink/sink/{Flink118TableSinkITCase.java => Flink118ComplexTypeITCase.java} (86%)
 copy fluss-flink/{fluss-flink-1.18/src/test/java/org/apache/fluss/flink/sink/Flink118TableSinkITCase.java => fluss-flink-1.19/src/test/java/org/apache/fluss/flink/sink/Flink119ComplexTypeITCase.java} (86%)
 copy fluss-flink/{fluss-flink-1.18/src/test/java/org/apache/fluss/flink/sink/Flink118TableSinkITCase.java => fluss-flink-1.20/src/test/java/org/apache/fluss/flink/sink/Flink120ComplexTypeITCase.java} (86%)
 copy fluss-flink/{fluss-flink-1.18/src/test/java/org/apache/fluss/flink/sink/Flink118TableSinkITCase.java => fluss-flink-2.1/src/test/java/org/apache/fluss/flink/sink/Flink21ComplexTypeITCase.java} (86%)
 create mode 100644 fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/sink/FlinkComplexTypeITCase.java