This is an automated email from the ASF dual-hosted git repository.
jinsongzhou pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/amoro.git
from 41bc8cf28 [Improvement]: Introduce TableRuntimeFactory interface
(#3760)
new 7ca00b4da [AMORO-3697] add Flink 1.18 support for mixed-format
new 4bdd974df fix flinksource test
new 3993f1309 fix checkstyle
new 1cc6d71a7 fix MixedFormatSourceEnumStateSerializer serialize see
flink 1.18 https://github.com/apache/flink/pull/21952/files
new b4cba4b11 fix MixedFormatSourceEnumStateSerializer serialize see
flink 1.18 https://github.com/apache/flink/pull/21952/files
The 5 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:
.../amoro-mixed-flink-common-format/pom.xml | 2 +-
.../pom.xml | 11 +-
.../apache/iceberg/flink/source/ScanContext.java | 182 +++++++++++++--------
.../amoro-mixed-flink-common/pom.xml | 14 +-
.../amoro/flink/lookup/RocksDBCacheState.java | 4 +-
.../amoro/flink/lookup/RocksDBSetSpilledState.java | 2 +-
.../read/hybrid/split/TemporalJoinSplits.java | 2 +-
.../amoro/flink/read/internals/KafkaSource.java | 2 +-
.../flink/read/source/MixedFormatScanContext.java | 10 +-
.../org/apache/amoro/flink/lookup/TestKVTable.java | 6 +-
.../hybrid/reader/TestRowDataReaderFunction.java | 2 +-
.../org/apache/amoro/flink/table/TestJoin.java | 2 +-
amoro-format-mixed/amoro-mixed-flink/pom.xml | 7 +-
.../amoro-mixed-flink-1.18}/pom.xml | 12 +-
.../amoro-mixed-flink-runtime-1.18}/pom.xml | 19 ++-
15 files changed, 174 insertions(+), 103 deletions(-)
copy amoro-format-mixed/amoro-mixed-flink/{v1.17/amoro-mixed-flink-1.17 =>
v1.18/amoro-mixed-flink-1.18}/pom.xml (91%)
copy
amoro-format-mixed/amoro-mixed-flink/{v1.17/amoro-mixed-flink-runtime-1.17 =>
v1.18/amoro-mixed-flink-runtime-1.18}/pom.xml (94%)