This is an automated email from the ASF dual-hosted git repository.
danny0405 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from e1f70fda589 [HUDI-8112] Fix
TestHoodieActiveTimeline#testTimelineGetOperations test logic error (#11814)
add d550b46d724 [HUDI-8070] Support Flink 1.19 (#11779)
No new revisions were added by this update.
Summary of changes:
.github/workflows/bot.yml | 19 ++++++++++------
.../hudi/sink/utils/BulkInsertFunctionWrapper.java | 5 +++--
.../hudi/sink/utils/ClusteringFunctionWrapper.java | 11 ++++-----
.../hudi/sink/utils/CompactFunctionWrapper.java | 9 ++++----
.../sink/utils/StreamWriteFunctionWrapper.java | 3 ++-
.../apache/hudi/adapter/CollectOutputAdapter.java} | 12 +++++-----
.../apache/hudi/adapter/CollectOutputAdapter.java} | 12 +++++-----
.../apache/hudi/adapter/CollectOutputAdapter.java} | 12 +++++-----
.../apache/hudi/adapter/CollectOutputAdapter.java} | 12 +++++-----
.../apache/hudi/adapter/CollectOutputAdapter.java} | 12 +++++-----
.../{hudi-flink1.18.x => hudi-flink1.19.x}/pom.xml | 22 +++++++++---------
.../apache/hudi/adapter/CollectOutputAdapter.java} | 16 ++++++++-----
.../adapter/DataStreamScanProviderAdapter.java | 0
.../adapter/DataStreamSinkProviderAdapter.java | 0
.../apache/hudi/adapter/HiveCatalogConstants.java | 0
.../apache/hudi/adapter/MaskingOutputAdapter.java | 6 +++++
.../hudi/adapter/OperatorCoordinatorAdapter.java | 0
.../hudi/adapter/SortCodeGeneratorAdapter.java | 0
.../adapter/SupportsRowLevelDeleteAdapter.java | 0
.../adapter/SupportsRowLevelUpdateAdapter.java | 0
.../main/java/org/apache/hudi/adapter/Utils.java | 0
.../table/format/cow/ParquetSplitReaderUtil.java | 0
.../table/format/cow/vector/HeapArrayVector.java | 0
.../table/format/cow/vector/HeapDecimalVector.java | 0
.../format/cow/vector/HeapMapColumnVector.java | 0
.../format/cow/vector/HeapRowColumnVector.java | 0
.../format/cow/vector/ParquetDecimalVector.java | 0
.../cow/vector/reader/AbstractColumnReader.java | 0
.../cow/vector/reader/ArrayColumnReader.java | 0
.../vector/reader/BaseVectorizedColumnReader.java | 0
.../cow/vector/reader/EmptyColumnReader.java | 0
.../vector/reader/FixedLenBytesColumnReader.java | 0
.../vector/reader/Int64TimestampColumnReader.java | 0
.../format/cow/vector/reader/MapColumnReader.java | 0
.../reader/ParquetColumnarRowSplitReader.java | 0
.../cow/vector/reader/ParquetDataColumnReader.java | 0
.../reader/ParquetDataColumnReaderFactory.java | 0
.../format/cow/vector/reader/RowColumnReader.java | 0
.../format/cow/vector/reader/RunLengthDecoder.java | 0
.../apache/hudi/adapter/TestHoodieCatalogs.java | 0
.../org/apache/hudi/adapter/TestStreamConfigs.java | 0
hudi-flink-datasource/pom.xml | 1 +
...ark350.sh => build_flink1190hive313spark350.sh} | 6 ++---
...h => build_flink1190hive313spark350scala213.sh} | 6 ++---
...h => build_flink1190hive313spark351scala213.sh} | 6 ++---
packaging/bundle-validation/ci_run.sh | 8 ++++---
pom.xml | 26 ++++++++++++++++++----
scripts/release/deploy_staging_jars.sh | 1 +
48 files changed, 124 insertions(+), 81 deletions(-)
copy
hudi-flink-datasource/{hudi-flink/src/test/java/org/apache/hudi/sink/utils/CollectorOutput.java
=>
hudi-flink1.14.x/src/main/java/org/apache/hudi/adapter/CollectOutputAdapter.java}
(89%)
copy
hudi-flink-datasource/{hudi-flink/src/test/java/org/apache/hudi/sink/utils/CollectorOutput.java
=>
hudi-flink1.15.x/src/main/java/org/apache/hudi/adapter/CollectOutputAdapter.java}
(89%)
copy
hudi-flink-datasource/{hudi-flink/src/test/java/org/apache/hudi/sink/utils/CollectorOutput.java
=>
hudi-flink1.16.x/src/main/java/org/apache/hudi/adapter/CollectOutputAdapter.java}
(89%)
copy
hudi-flink-datasource/{hudi-flink/src/test/java/org/apache/hudi/sink/utils/CollectorOutput.java
=>
hudi-flink1.17.x/src/main/java/org/apache/hudi/adapter/CollectOutputAdapter.java}
(89%)
copy
hudi-flink-datasource/{hudi-flink/src/test/java/org/apache/hudi/sink/utils/CollectorOutput.java
=>
hudi-flink1.18.x/src/main/java/org/apache/hudi/adapter/CollectOutputAdapter.java}
(89%)
copy hudi-flink-datasource/{hudi-flink1.18.x => hudi-flink1.19.x}/pom.xml (90%)
rename
hudi-flink-datasource/{hudi-flink/src/test/java/org/apache/hudi/sink/utils/CollectorOutput.java
=>
hudi-flink1.19.x/src/main/java/org/apache/hudi/adapter/CollectOutputAdapter.java}
(82%)
copy hudi-flink-datasource/{hudi-flink1.15.x =>
hudi-flink1.19.x}/src/main/java/org/apache/hudi/adapter/DataStreamScanProviderAdapter.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.15.x =>
hudi-flink1.19.x}/src/main/java/org/apache/hudi/adapter/DataStreamSinkProviderAdapter.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.18.x =>
hudi-flink1.19.x}/src/main/java/org/apache/hudi/adapter/HiveCatalogConstants.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.14.x =>
hudi-flink1.19.x}/src/main/java/org/apache/hudi/adapter/MaskingOutputAdapter.java
(91%)
copy hudi-flink-datasource/{hudi-flink1.16.x =>
hudi-flink1.19.x}/src/main/java/org/apache/hudi/adapter/OperatorCoordinatorAdapter.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.16.x =>
hudi-flink1.19.x}/src/main/java/org/apache/hudi/adapter/SortCodeGeneratorAdapter.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.17.x =>
hudi-flink1.19.x}/src/main/java/org/apache/hudi/adapter/SupportsRowLevelDeleteAdapter.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.17.x =>
hudi-flink1.19.x}/src/main/java/org/apache/hudi/adapter/SupportsRowLevelUpdateAdapter.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.18.x =>
hudi-flink1.19.x}/src/main/java/org/apache/hudi/adapter/Utils.java (100%)
copy hudi-flink-datasource/{hudi-flink1.15.x =>
hudi-flink1.19.x}/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.15.x =>
hudi-flink1.19.x}/src/main/java/org/apache/hudi/table/format/cow/vector/HeapArrayVector.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.15.x =>
hudi-flink1.19.x}/src/main/java/org/apache/hudi/table/format/cow/vector/HeapDecimalVector.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.15.x =>
hudi-flink1.19.x}/src/main/java/org/apache/hudi/table/format/cow/vector/HeapMapColumnVector.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.15.x =>
hudi-flink1.19.x}/src/main/java/org/apache/hudi/table/format/cow/vector/HeapRowColumnVector.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.15.x =>
hudi-flink1.19.x}/src/main/java/org/apache/hudi/table/format/cow/vector/ParquetDecimalVector.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.18.x =>
hudi-flink1.19.x}/src/main/java/org/apache/hudi/table/format/cow/vector/reader/AbstractColumnReader.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.15.x =>
hudi-flink1.19.x}/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ArrayColumnReader.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.15.x =>
hudi-flink1.19.x}/src/main/java/org/apache/hudi/table/format/cow/vector/reader/BaseVectorizedColumnReader.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.15.x =>
hudi-flink1.19.x}/src/main/java/org/apache/hudi/table/format/cow/vector/reader/EmptyColumnReader.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.15.x =>
hudi-flink1.19.x}/src/main/java/org/apache/hudi/table/format/cow/vector/reader/FixedLenBytesColumnReader.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.15.x =>
hudi-flink1.19.x}/src/main/java/org/apache/hudi/table/format/cow/vector/reader/Int64TimestampColumnReader.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.15.x =>
hudi-flink1.19.x}/src/main/java/org/apache/hudi/table/format/cow/vector/reader/MapColumnReader.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.15.x =>
hudi-flink1.19.x}/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ParquetColumnarRowSplitReader.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.14.x =>
hudi-flink1.19.x}/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ParquetDataColumnReader.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.14.x =>
hudi-flink1.19.x}/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ParquetDataColumnReaderFactory.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.15.x =>
hudi-flink1.19.x}/src/main/java/org/apache/hudi/table/format/cow/vector/reader/RowColumnReader.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.15.x =>
hudi-flink1.19.x}/src/main/java/org/apache/hudi/table/format/cow/vector/reader/RunLengthDecoder.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.17.x =>
hudi-flink1.19.x}/src/test/java/org/apache/hudi/adapter/TestHoodieCatalogs.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.16.x =>
hudi-flink1.19.x}/src/test/java/org/apache/hudi/adapter/TestStreamConfigs.java
(100%)
copy packaging/bundle-validation/base/{build_flink1180hive313spark350.sh =>
build_flink1190hive313spark350.sh} (81%)
copy
packaging/bundle-validation/base/{build_flink1180hive313spark350scala213.sh =>
build_flink1190hive313spark350scala213.sh} (84%)
copy
packaging/bundle-validation/base/{build_flink1180hive313spark351scala213.sh =>
build_flink1190hive313spark351scala213.sh} (84%)
