This is an automated email from the ASF dual-hosted git repository.
sivabalan pushed a change to branch release-0.12.2-blockers-candidate
in repository https://gitbox.apache.org/repos/asf/hudi.git
from 492f7d737ec [HUDI-5097] Fix partition reading without partition fields
table config (#7069)
add fe86a83345c Cherry pick for HUDI-5007 and HUDI-5228 (#7471)
No new revisions were added by this update.
Summary of changes:
.../client/common/HoodieFlinkEngineContext.java | 4 +
.../apache/hudi/configuration/OptionsResolver.java | 7 +
.../java/org/apache/hudi/sink/CleanFunction.java | 4 +-
.../hudi/sink/StreamWriteOperatorCoordinator.java | 3 +-
.../hudi/sink/bootstrap/BootstrapOperator.java | 4 +-
.../hudi/sink/bulk/BulkInsertWriteFunction.java | 4 +-
.../hudi/sink/clustering/ClusteringCommitSink.java | 3 +-
.../hudi/sink/clustering/ClusteringOperator.java | 6 +-
.../sink/clustering/ClusteringPlanOperator.java | 4 +-
.../sink/clustering/HoodieFlinkClusteringJob.java | 3 +-
.../sink/common/AbstractStreamWriteFunction.java | 3 +-
.../apache/hudi/sink/compact/CompactFunction.java | 4 +-
.../hudi/sink/compact/CompactionCommitSink.java | 4 +-
.../hudi/sink/compact/HoodieFlinkCompactor.java | 3 +-
.../sink/partitioner/BucketAssignFunction.java | 4 +-
.../apache/hudi/source/IncrementalInputSplits.java | 13 +-
.../org/apache/hudi/table/format/FormatUtils.java | 3 +-
.../java/org/apache/hudi/util/FlinkTables.java | 5 +-
.../org/apache/hudi/util/FlinkWriteClients.java | 238 +++++++++++++++++++++
.../java/org/apache/hudi/util/StreamerUtil.java | 174 ---------------
.../org/apache/hudi/sink/TestWriteCopyOnWrite.java | 6 +-
.../sink/cluster/ITTestHoodieFlinkClustering.java | 5 +-
.../sink/compact/ITTestHoodieFlinkCompactor.java | 7 +-
.../hudi/sink/partitioner/TestBucketAssigner.java | 5 +-
.../hudi/source/TestIncrementalInputSplits.java | 88 ++++++++
.../apache/hudi/table/format/TestInputFormat.java | 3 +-
.../org/apache/hudi/utils/TestCompactionUtil.java | 3 +-
.../org/apache/hudi/utils/TestStreamerUtil.java | 11 -
.../hudi/utils/TestViewStorageProperties.java | 10 +
29 files changed, 407 insertions(+), 224 deletions(-)
create mode 100644
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/FlinkWriteClients.java
create mode 100644
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/TestIncrementalInputSplits.java
