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 dfe1674992b [Minor] Fixed twitter link to redirect to twitter (#10139)
add b2f44935824 [HUDI-7072] Remove support for Flink 1.13 (#10052)
No new revisions were added by this update.
Summary of changes:
.github/workflows/bot.yml | 11 +-
README.md | 5 -
azure-pipelines-20230430.yml | 3 -
.../RowDataToHoodieFunctionWithRateLimit.java | 10 +-
.../org/apache/hudi/source/StreamReadOperator.java | 41 +-
.../apache/hudi/sink/utils/CollectorOutput.java | 10 +-
.../sink/utils/MockStateInitializationContext.java | 12 +-
.../sink/utils/MockStreamingRuntimeContext.java | 11 +-
.../apache/hudi/table/ITTestHoodieDataSource.java | 2 +-
.../table/catalog/TestHoodieCatalogFactory.java | 2 +-
.../java/org/apache/hudi/utils}/TestTableEnvs.java | 2 +-
hudi-flink-datasource/hudi-flink1.13.x/pom.xml | 144 -----
.../adapter/AbstractStreamOperatorAdapter.java | 35 --
.../AbstractStreamOperatorFactoryAdapter.java | 50 --
.../adapter/DataStreamScanProviderAdapter.java | 27 -
.../adapter/DataStreamSinkProviderAdapter.java | 27 -
.../apache/hudi/adapter/HiveCatalogConstants.java | 51 --
.../hudi/adapter/MailboxExecutorAdapter.java | 37 --
.../apache/hudi/adapter/MaskingOutputAdapter.java | 61 ---
.../hudi/adapter/OperatorCoordinatorAdapter.java | 27 -
.../apache/hudi/adapter/RateLimiterAdapter.java | 40 --
.../hudi/adapter/SortCodeGeneratorAdapter.java | 33 --
.../adapter/SupportsRowLevelDeleteAdapter.java | 33 --
.../adapter/SupportsRowLevelUpdateAdapter.java | 37 --
.../main/java/org/apache/hudi/adapter/Utils.java | 83 ---
.../apache/hudi/table/data/ColumnarArrayData.java | 270 ----------
.../apache/hudi/table/data/ColumnarMapData.java | 73 ---
.../apache/hudi/table/data/ColumnarRowData.java | 231 --------
.../hudi/table/data/vector/MapColumnVector.java | 29 --
.../hudi/table/data/vector/RowColumnVector.java | 30 --
.../table/data/vector/VectorizedColumnBatch.java | 148 ------
.../table/format/cow/ParquetSplitReaderUtil.java | 579 ---------------------
.../table/format/cow/vector/HeapArrayVector.java | 71 ---
.../format/cow/vector/HeapMapColumnVector.java | 80 ---
.../format/cow/vector/HeapRowColumnVector.java | 55 --
.../format/cow/vector/ParquetDecimalVector.java | 54 --
.../cow/vector/reader/AbstractColumnReader.java | 325 ------------
.../cow/vector/reader/ArrayColumnReader.java | 473 -----------------
.../vector/reader/BaseVectorizedColumnReader.java | 313 -----------
.../cow/vector/reader/EmptyColumnReader.java | 41 --
.../vector/reader/FixedLenBytesColumnReader.java | 84 ---
.../vector/reader/Int64TimestampColumnReader.java | 119 -----
.../format/cow/vector/reader/MapColumnReader.java | 76 ---
.../reader/ParquetColumnarRowSplitReader.java | 390 --------------
.../cow/vector/reader/ParquetDataColumnReader.java | 199 -------
.../reader/ParquetDataColumnReaderFactory.java | 304 -----------
.../format/cow/vector/reader/RowColumnReader.java | 63 ---
.../format/cow/vector/reader/RunLengthDecoder.java | 304 -----------
.../org/apache/hudi/adapter/OutputAdapter.java | 27 -
.../adapter/StateInitializationContextAdapter.java | 26 -
.../adapter/StreamingRuntimeContextAdapter.java | 43 --
.../org/apache/hudi/adapter/TestStreamConfigs.java | 32 --
.../org/apache/hudi/adapter/TestTableEnvs.java | 34 --
.../adapter/AbstractStreamOperatorAdapter.java | 27 -
.../AbstractStreamOperatorFactoryAdapter.java | 33 --
.../hudi/adapter/MailboxExecutorAdapter.java | 37 --
.../apache/hudi/adapter/RateLimiterAdapter.java | 40 --
.../main/java/org/apache/hudi/adapter/Utils.java | 23 -
.../org/apache/hudi/adapter/OutputAdapter.java | 32 --
.../adapter/StateInitializationContextAdapter.java | 32 --
.../adapter/StreamingRuntimeContextAdapter.java | 43 --
.../adapter/AbstractStreamOperatorAdapter.java | 27 -
.../AbstractStreamOperatorFactoryAdapter.java | 33 --
.../hudi/adapter/MailboxExecutorAdapter.java | 37 --
.../apache/hudi/adapter/RateLimiterAdapter.java | 40 --
.../main/java/org/apache/hudi/adapter/Utils.java | 23 -
.../org/apache/hudi/adapter/OutputAdapter.java | 32 --
.../adapter/StateInitializationContextAdapter.java | 31 --
.../adapter/StreamingRuntimeContextAdapter.java | 43 --
.../org/apache/hudi/adapter/TestTableEnvs.java | 52 --
.../adapter/AbstractStreamOperatorAdapter.java | 27 -
.../AbstractStreamOperatorFactoryAdapter.java | 33 --
.../hudi/adapter/MailboxExecutorAdapter.java | 37 --
.../apache/hudi/adapter/RateLimiterAdapter.java | 40 --
.../main/java/org/apache/hudi/adapter/Utils.java | 23 -
.../org/apache/hudi/adapter/OutputAdapter.java | 32 --
.../adapter/StateInitializationContextAdapter.java | 31 --
.../adapter/StreamingRuntimeContextAdapter.java | 43 --
.../org/apache/hudi/adapter/TestTableEnvs.java | 52 --
.../adapter/AbstractStreamOperatorAdapter.java | 27 -
.../AbstractStreamOperatorFactoryAdapter.java | 33 --
.../hudi/adapter/MailboxExecutorAdapter.java | 37 --
.../apache/hudi/adapter/RateLimiterAdapter.java | 40 --
.../main/java/org/apache/hudi/adapter/Utils.java | 23 -
.../org/apache/hudi/adapter/OutputAdapter.java | 32 --
.../adapter/StateInitializationContextAdapter.java | 31 --
.../adapter/StreamingRuntimeContextAdapter.java | 43 --
.../org/apache/hudi/adapter/TestTableEnvs.java | 52 --
.../adapter/AbstractStreamOperatorAdapter.java | 27 -
.../AbstractStreamOperatorFactoryAdapter.java | 33 --
.../hudi/adapter/MailboxExecutorAdapter.java | 37 --
.../apache/hudi/adapter/RateLimiterAdapter.java | 40 --
.../main/java/org/apache/hudi/adapter/Utils.java | 25 +-
.../org/apache/hudi/adapter/OutputAdapter.java | 32 --
.../adapter/StateInitializationContextAdapter.java | 31 --
.../adapter/StreamingRuntimeContextAdapter.java | 43 --
.../org/apache/hudi/adapter/TestTableEnvs.java | 52 --
hudi-flink-datasource/pom.xml | 1 -
packaging/bundle-validation/README.md | 8 +-
packaging/bundle-validation/ci_run.sh | 12 +-
packaging/bundle-validation/run_docker_java17.sh | 8 +-
pom.xml | 28 -
scripts/release/deploy_staging_jars.sh | 1 -
scripts/release/validate_staged_bundles.sh | 2 +-
104 files changed, 82 insertions(+), 6786 deletions(-)
rename
hudi-flink-datasource/{hudi-flink1.14.x/src/test/java/org/apache/hudi/adapter
=> hudi-flink/src/test/java/org/apache/hudi/utils}/TestTableEnvs.java (98%)
delete mode 100644 hudi-flink-datasource/hudi-flink1.13.x/pom.xml
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/adapter/AbstractStreamOperatorAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/adapter/AbstractStreamOperatorFactoryAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/adapter/DataStreamScanProviderAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/adapter/DataStreamSinkProviderAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/adapter/HiveCatalogConstants.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/adapter/MailboxExecutorAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/adapter/MaskingOutputAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/adapter/OperatorCoordinatorAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/adapter/RateLimiterAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/adapter/SortCodeGeneratorAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/adapter/SupportsRowLevelDeleteAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/adapter/SupportsRowLevelUpdateAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/adapter/Utils.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/table/data/ColumnarArrayData.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/table/data/ColumnarMapData.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/table/data/ColumnarRowData.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/table/data/vector/MapColumnVector.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/table/data/vector/RowColumnVector.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/table/data/vector/VectorizedColumnBatch.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/table/format/cow/vector/HeapArrayVector.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/table/format/cow/vector/HeapMapColumnVector.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/table/format/cow/vector/HeapRowColumnVector.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/table/format/cow/vector/ParquetDecimalVector.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/AbstractColumnReader.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ArrayColumnReader.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/BaseVectorizedColumnReader.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/EmptyColumnReader.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/FixedLenBytesColumnReader.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/Int64TimestampColumnReader.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/MapColumnReader.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ParquetColumnarRowSplitReader.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ParquetDataColumnReader.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ParquetDataColumnReaderFactory.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/RowColumnReader.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/RunLengthDecoder.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/test/java/org/apache/hudi/adapter/OutputAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/test/java/org/apache/hudi/adapter/StateInitializationContextAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/test/java/org/apache/hudi/adapter/StreamingRuntimeContextAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/test/java/org/apache/hudi/adapter/TestStreamConfigs.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.13.x/src/test/java/org/apache/hudi/adapter/TestTableEnvs.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/adapter/AbstractStreamOperatorAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/adapter/AbstractStreamOperatorFactoryAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/adapter/MailboxExecutorAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/adapter/RateLimiterAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.14.x/src/test/java/org/apache/hudi/adapter/OutputAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.14.x/src/test/java/org/apache/hudi/adapter/StateInitializationContextAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.14.x/src/test/java/org/apache/hudi/adapter/StreamingRuntimeContextAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/adapter/AbstractStreamOperatorAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/adapter/AbstractStreamOperatorFactoryAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/adapter/MailboxExecutorAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/adapter/RateLimiterAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.15.x/src/test/java/org/apache/hudi/adapter/OutputAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.15.x/src/test/java/org/apache/hudi/adapter/StateInitializationContextAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.15.x/src/test/java/org/apache/hudi/adapter/StreamingRuntimeContextAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.15.x/src/test/java/org/apache/hudi/adapter/TestTableEnvs.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/adapter/AbstractStreamOperatorAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/adapter/AbstractStreamOperatorFactoryAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/adapter/MailboxExecutorAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/adapter/RateLimiterAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.16.x/src/test/java/org/apache/hudi/adapter/OutputAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.16.x/src/test/java/org/apache/hudi/adapter/StateInitializationContextAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.16.x/src/test/java/org/apache/hudi/adapter/StreamingRuntimeContextAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.16.x/src/test/java/org/apache/hudi/adapter/TestTableEnvs.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/adapter/AbstractStreamOperatorAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/adapter/AbstractStreamOperatorFactoryAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/adapter/MailboxExecutorAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/adapter/RateLimiterAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.17.x/src/test/java/org/apache/hudi/adapter/OutputAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.17.x/src/test/java/org/apache/hudi/adapter/StateInitializationContextAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.17.x/src/test/java/org/apache/hudi/adapter/StreamingRuntimeContextAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.17.x/src/test/java/org/apache/hudi/adapter/TestTableEnvs.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/adapter/AbstractStreamOperatorAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/adapter/AbstractStreamOperatorFactoryAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/adapter/MailboxExecutorAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/adapter/RateLimiterAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.18.x/src/test/java/org/apache/hudi/adapter/OutputAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.18.x/src/test/java/org/apache/hudi/adapter/StateInitializationContextAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.18.x/src/test/java/org/apache/hudi/adapter/StreamingRuntimeContextAdapter.java
delete mode 100644
hudi-flink-datasource/hudi-flink1.18.x/src/test/java/org/apache/hudi/adapter/TestTableEnvs.java
