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 2f5e487445 [HUDI-5492] spark call command 'show_compaction' doesn't
return the completed compaction (#7593)
add a80bb4f717 [HUDI-5205] Support flink 1.16.0 (#7584)
No new revisions were added by this update.
Summary of changes:
.github/workflows/bot.yml | 3 ++
.../hudi/sink/StreamWriteOperatorCoordinator.java | 6 ++--
.../hudi/sink/bulk/sort/SortOperatorGen.java | 4 ++-
.../hudi/table/catalog/HoodieHiveCatalog.java | 6 ++--
.../apache/hudi/table/ITTestHoodieDataSource.java | 6 ++--
.../hudi/utils/source/ContinuousFileSource.java | 31 ++++++++++++++++--
hudi-flink-datasource/hudi-flink1.13.x/pom.xml | 12 +++++--
.../hudi/adapter/OperatorCoordinatorAdapter.java} | 6 ++--
.../hudi/adapter/SortCodeGeneratorAdapter.java} | 23 +++++++------
hudi-flink-datasource/hudi-flink1.14.x/pom.xml | 12 +++++--
.../hudi/adapter/OperatorCoordinatorAdapter.java} | 6 ++--
.../hudi/adapter/SortCodeGeneratorAdapter.java} | 23 +++++++------
hudi-flink-datasource/hudi-flink1.15.x/pom.xml | 12 +++++--
.../hudi/adapter/OperatorCoordinatorAdapter.java} | 6 ++--
.../hudi/adapter/SortCodeGeneratorAdapter.java} | 23 +++++++------
.../{hudi-flink1.15.x => hudi-flink1.16.x}/pom.xml | 30 ++++++++++-------
.../adapter/AbstractStreamOperatorAdapter.java | 0
.../AbstractStreamOperatorFactoryAdapter.java | 0
.../adapter/DataStreamScanProviderAdapter.java | 0
.../adapter/DataStreamSinkProviderAdapter.java | 0
.../hudi/adapter/MailboxExecutorAdapter.java | 0
.../hudi/adapter/OperatorCoordinatorAdapter.java} | 38 +++++++++++-----------
.../apache/hudi/adapter/RateLimiterAdapter.java | 0
.../hudi/adapter/SortCodeGeneratorAdapter.java} | 23 +++++--------
.../main/java/org/apache/hudi/adapter/Utils.java | 0
.../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 | 18 ++++++++--
scripts/release/deploy_staging_jars.sh | 1 +
scripts/release/validate_staged_bundles.sh | 1 +
49 files changed, 181 insertions(+), 110 deletions(-)
copy
hudi-flink-datasource/hudi-flink1.13.x/src/{test/java/org/apache/hudi/adapter/OutputAdapter.java
=> main/java/org/apache/hudi/adapter/OperatorCoordinatorAdapter.java} (80%)
copy
hudi-flink-datasource/hudi-flink1.13.x/src/{test/java/org/apache/hudi/adapter/TestTableEnvs.java
=> main/java/org/apache/hudi/adapter/SortCodeGeneratorAdapter.java} (64%)
copy
hudi-flink-datasource/{hudi-flink1.13.x/src/test/java/org/apache/hudi/adapter/OutputAdapter.java
=>
hudi-flink1.14.x/src/main/java/org/apache/hudi/adapter/OperatorCoordinatorAdapter.java}
(80%)
copy
hudi-flink-datasource/{hudi-flink1.13.x/src/test/java/org/apache/hudi/adapter/TestTableEnvs.java
=>
hudi-flink1.14.x/src/main/java/org/apache/hudi/adapter/SortCodeGeneratorAdapter.java}
(63%)
copy
hudi-flink-datasource/{hudi-flink1.13.x/src/test/java/org/apache/hudi/adapter/OutputAdapter.java
=>
hudi-flink1.15.x/src/main/java/org/apache/hudi/adapter/OperatorCoordinatorAdapter.java}
(80%)
copy
hudi-flink-datasource/{hudi-flink1.13.x/src/test/java/org/apache/hudi/adapter/TestTableEnvs.java
=>
hudi-flink1.15.x/src/main/java/org/apache/hudi/adapter/SortCodeGeneratorAdapter.java}
(63%)
copy hudi-flink-datasource/{hudi-flink1.15.x => hudi-flink1.16.x}/pom.xml (90%)
copy hudi-flink-datasource/{hudi-flink1.14.x =>
hudi-flink1.16.x}/src/main/java/org/apache/hudi/adapter/AbstractStreamOperatorAdapter.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.14.x =>
hudi-flink1.16.x}/src/main/java/org/apache/hudi/adapter/AbstractStreamOperatorFactoryAdapter.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.15.x =>
hudi-flink1.16.x}/src/main/java/org/apache/hudi/adapter/DataStreamScanProviderAdapter.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.15.x =>
hudi-flink1.16.x}/src/main/java/org/apache/hudi/adapter/DataStreamSinkProviderAdapter.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.14.x =>
hudi-flink1.16.x}/src/main/java/org/apache/hudi/adapter/MailboxExecutorAdapter.java
(100%)
copy
hudi-flink-datasource/{hudi-flink/src/main/java/org/apache/hudi/sink/bulk/BulkInsertWriteOperator.java
=>
hudi-flink1.16.x/src/main/java/org/apache/hudi/adapter/OperatorCoordinatorAdapter.java}
(50%)
copy hudi-flink-datasource/{hudi-flink1.14.x =>
hudi-flink1.16.x}/src/main/java/org/apache/hudi/adapter/RateLimiterAdapter.java
(100%)
copy
hudi-flink-datasource/{hudi-flink1.13.x/src/main/java/org/apache/hudi/adapter/RateLimiterAdapter.java
=>
hudi-flink1.16.x/src/main/java/org/apache/hudi/adapter/SortCodeGeneratorAdapter.java}
(60%)
copy hudi-flink-datasource/{hudi-flink1.15.x =>
hudi-flink1.16.x}/src/main/java/org/apache/hudi/adapter/Utils.java (100%)
copy hudi-flink-datasource/{hudi-flink1.15.x =>
hudi-flink1.16.x}/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.15.x =>
hudi-flink1.16.x}/src/main/java/org/apache/hudi/table/format/cow/vector/HeapArrayVector.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.15.x =>
hudi-flink1.16.x}/src/main/java/org/apache/hudi/table/format/cow/vector/HeapMapColumnVector.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.15.x =>
hudi-flink1.16.x}/src/main/java/org/apache/hudi/table/format/cow/vector/HeapRowColumnVector.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.15.x =>
hudi-flink1.16.x}/src/main/java/org/apache/hudi/table/format/cow/vector/ParquetDecimalVector.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.15.x =>
hudi-flink1.16.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.16.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.16.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.16.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.16.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.16.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.16.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.16.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.16.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.16.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.16.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.16.x}/src/test/java/org/apache/hudi/adapter/OutputAdapter.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.15.x =>
hudi-flink1.16.x}/src/test/java/org/apache/hudi/adapter/StateInitializationContextAdapter.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.14.x =>
hudi-flink1.16.x}/src/test/java/org/apache/hudi/adapter/StreamingRuntimeContextAdapter.java
(100%)
copy hudi-flink-datasource/{hudi-flink1.14.x =>
hudi-flink1.16.x}/src/test/java/org/apache/hudi/adapter/TestTableEnvs.java
(100%)
