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%)