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 d3f957755a [HUDI-5223] Partial failover for flink (#7208)
add dc5cc08ccc [HUDI-5228] Flink table service job fs view conf overwrites
the one of writing job (#7214)
No new revisions were added by this update.
Summary of changes:
.../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/table/catalog/HoodieCatalog.java | 5 +-
.../hudi/table/catalog/HoodieHiveCatalog.java | 5 +-
.../org/apache/hudi/table/format/FormatUtils.java | 3 +-
.../hudi/table/format/cdc/CdcInputFormat.java | 3 +-
.../java/org/apache/hudi/util/FlinkTables.java | 5 +-
.../org/apache/hudi/util/FlinkWriteClients.java | 238 +++++++++++++++++++++
.../java/org/apache/hudi/util/StreamerUtil.java | 177 ---------------
.../org/apache/hudi/sink/TestWriteCopyOnWrite.java | 6 +-
.../sink/cluster/ITTestHoodieFlinkClustering.java | 5 +-
.../sink/compact/ITTestHoodieFlinkCompactor.java | 7 +-
.../hudi/sink/partitioner/TestBucketAssigner.java | 5 +-
.../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 +
28 files changed, 304 insertions(+), 231 deletions(-)
create mode 100644
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/FlinkWriteClients.java
