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
