You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by da...@apache.org on 2023/04/27 02:13:54 UTC
[hudi] branch master updated (0894279a0b7 -> 2ef682012b8)
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 0894279a0b7 [HUDI-6124] Optimize exception message in HoodieCatalogTable (#8543)
add 2ef682012b8 [HUDI-6057] Support Flink 1.17 (#8512)
No new revisions were added by this update.
Summary of changes:
.github/workflows/bot.yml | 3 +++
README.md | 7 +++---
azure-pipelines.yml | 5 +++-
.../apache/hudi/sink/bulk/sort/SortOperator.java | 12 ++++++---
.../hudi/sink/bulk/sort/SortOperatorGen.java | 6 +++--
.../hudi/sink/clustering/ClusteringOperator.java | 6 ++---
.../java/org/apache/hudi/sink/utils/Pipelines.java | 4 +--
.../org/apache/hudi/table/HoodieTableFactory.java | 28 +++++++++++++++++++++
.../main/java/org/apache/hudi/adapter/Utils.java | 23 +++++++++++++++++
.../main/java/org/apache/hudi/adapter/Utils.java | 23 +++++++++++++++++
.../main/java/org/apache/hudi/adapter/Utils.java | 23 +++++++++++++++++
.../main/java/org/apache/hudi/adapter/Utils.java | 23 +++++++++++++++++
.../{hudi-flink1.16.x => hudi-flink1.17.x}/pom.xml | 20 +++++++--------
.../adapter/AbstractStreamOperatorAdapter.java | 0
.../AbstractStreamOperatorFactoryAdapter.java | 0
.../adapter/DataStreamScanProviderAdapter.java | 0
.../adapter/DataStreamSinkProviderAdapter.java | 0
.../hudi/adapter/MailboxExecutorAdapter.java | 0
.../apache/hudi/adapter/MaskingOutputAdapter.java | 0
.../hudi/adapter/OperatorCoordinatorAdapter.java | 0
.../apache/hudi/adapter/RateLimiterAdapter.java | 0
.../hudi/adapter/SortCodeGeneratorAdapter.java | 0
.../main/java/org/apache/hudi/adapter/Utils.java | 29 ++++++++++++++++++++++
.../table/format/cow/ParquetSplitReaderUtil.java | 0
.../table/format/cow/vector/HeapArrayVector.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
.../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
.../org/apache/hudi/adapter/OutputAdapter.java | 0
.../adapter/StateInitializationContextAdapter.java | 0
.../adapter/StreamingRuntimeContextAdapter.java | 0
.../org/apache/hudi/adapter/TestTableEnvs.java | 0
hudi-flink-datasource/pom.xml | 1 +
pom.xml | 28 ++++++++++++++++++---
scripts/release/deploy_staging_jars.sh | 3 ++-
scripts/release/validate_staged_bundles.sh | 1 +
47 files changed, 216 insertions(+), 29 deletions(-)
copy hudi-flink-datasource/{hudi-flink1.16.x => hudi-flink1.17.x}/pom.xml (93%)
copy hudi-flink-datasource/{hudi-flink1.14.x => hudi-flink1.17.x}/src/main/java/org/apache/hudi/adapter/AbstractStreamOperatorAdapter.java (100%)
copy hudi-flink-datasource/{hudi-flink1.14.x => hudi-flink1.17.x}/src/main/java/org/apache/hudi/adapter/AbstractStreamOperatorFactoryAdapter.java (100%)
copy hudi-flink-datasource/{hudi-flink1.15.x => hudi-flink1.17.x}/src/main/java/org/apache/hudi/adapter/DataStreamScanProviderAdapter.java (100%)
copy hudi-flink-datasource/{hudi-flink1.15.x => hudi-flink1.17.x}/src/main/java/org/apache/hudi/adapter/DataStreamSinkProviderAdapter.java (100%)
copy hudi-flink-datasource/{hudi-flink1.14.x => hudi-flink1.17.x}/src/main/java/org/apache/hudi/adapter/MailboxExecutorAdapter.java (100%)
copy hudi-flink-datasource/{hudi-flink1.14.x => hudi-flink1.17.x}/src/main/java/org/apache/hudi/adapter/MaskingOutputAdapter.java (100%)
copy hudi-flink-datasource/{hudi-flink1.16.x => hudi-flink1.17.x}/src/main/java/org/apache/hudi/adapter/OperatorCoordinatorAdapter.java (100%)
copy hudi-flink-datasource/{hudi-flink1.14.x => hudi-flink1.17.x}/src/main/java/org/apache/hudi/adapter/RateLimiterAdapter.java (100%)
copy hudi-flink-datasource/{hudi-flink1.16.x => hudi-flink1.17.x}/src/main/java/org/apache/hudi/adapter/SortCodeGeneratorAdapter.java (100%)
copy hudi-flink-datasource/{hudi-flink1.16.x => hudi-flink1.17.x}/src/main/java/org/apache/hudi/adapter/Utils.java (61%)
copy hudi-flink-datasource/{hudi-flink1.15.x => hudi-flink1.17.x}/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java (100%)
copy hudi-flink-datasource/{hudi-flink1.15.x => hudi-flink1.17.x}/src/main/java/org/apache/hudi/table/format/cow/vector/HeapArrayVector.java (100%)
copy hudi-flink-datasource/{hudi-flink1.15.x => hudi-flink1.17.x}/src/main/java/org/apache/hudi/table/format/cow/vector/HeapMapColumnVector.java (100%)
copy hudi-flink-datasource/{hudi-flink1.15.x => hudi-flink1.17.x}/src/main/java/org/apache/hudi/table/format/cow/vector/HeapRowColumnVector.java (100%)
copy hudi-flink-datasource/{hudi-flink1.15.x => hudi-flink1.17.x}/src/main/java/org/apache/hudi/table/format/cow/vector/ParquetDecimalVector.java (100%)
copy hudi-flink-datasource/{hudi-flink1.15.x => hudi-flink1.17.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.17.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.17.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.17.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.17.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.17.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.17.x}/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ParquetColumnarRowSplitReader.java (100%)
copy hudi-flink-datasource/{hudi-flink1.13.x => hudi-flink1.17.x}/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ParquetDataColumnReader.java (100%)
copy hudi-flink-datasource/{hudi-flink1.13.x => hudi-flink1.17.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.17.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.17.x}/src/main/java/org/apache/hudi/table/format/cow/vector/reader/RunLengthDecoder.java (100%)
copy hudi-flink-datasource/{hudi-flink1.14.x => hudi-flink1.17.x}/src/test/java/org/apache/hudi/adapter/OutputAdapter.java (100%)
copy hudi-flink-datasource/{hudi-flink1.15.x => hudi-flink1.17.x}/src/test/java/org/apache/hudi/adapter/StateInitializationContextAdapter.java (100%)
copy hudi-flink-datasource/{hudi-flink1.14.x => hudi-flink1.17.x}/src/test/java/org/apache/hudi/adapter/StreamingRuntimeContextAdapter.java (100%)
copy hudi-flink-datasource/{hudi-flink1.14.x => hudi-flink1.17.x}/src/test/java/org/apache/hudi/adapter/TestTableEnvs.java (100%)