This is an automated email from the ASF dual-hosted git repository.
sivabalan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from 95d8c6b9232 [HUDI-5569] Maintain commit timeline even in case of long
standing inflights (#8783)
add fca3307f42d [HUDI-6288] Create
IngestionPrimaryWriterBasedConflictResolutionStrategy to prioritize ingestion
writers over other writers (#8832)
No new revisions were added by this update.
Summary of changes:
.../hudi/client/BaseHoodieTableServiceClient.java | 10 +
.../client/transaction/ConcurrentOperation.java | 9 +
.../transaction/ConflictResolutionStrategy.java | 11 +-
...imaryWriterBasedConflictResolutionStrategy.java | 116 +++++++
...urrentFileWritesConflictResolutionStrategy.java | 12 +-
.../apache/hudi/client/utils/TransactionUtils.java | 12 +-
...urrentFileWritesConflictResolutionStrategy.java | 12 +-
.../TestConflictResolutionStrategyUtil.java | 285 ++++++++++++++++
...imaryWriterBasedConflictResolutionStrategy.java | 260 +++++++++++++++
...urrentFileWritesConflictResolutionStrategy.java | 363 +++++----------------
.../hudi/client/HoodieFlinkTableServiceClient.java | 9 +-
.../hudi/client/SparkRDDTableServiceClient.java | 5 +
.../hudi/client/TestHoodieClientMultiWriter.java | 91 ++++--
...estMultiwriterWithIngestionAsPrimaryWriter.java | 256 +++++++++++++++
.../functional/TestHoodieBackedMetadata.java | 2 +-
.../TestHoodieClientOnCopyOnWriteStorage.java | 145 ++++++++
.../table/timeline/HoodieDefaultTimeline.java | 7 +
.../hudi/common/table/timeline/HoodieInstant.java | 1 -
.../hudi/common/table/timeline/HoodieTimeline.java | 5 +
.../view/HoodieTablePreCommitFileSystemView.java | 2 +-
.../apache/hudi/common/util/ClusteringUtils.java | 7 +
.../org/apache/hudi/common/util/CommitUtils.java | 7 +
.../hudi/common/testutils/HoodieTestTable.java | 3 -
23 files changed, 1291 insertions(+), 339 deletions(-)
create mode 100644
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/transaction/IngestionPrimaryWriterBasedConflictResolutionStrategy.java
create mode 100644
hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/transaction/TestConflictResolutionStrategyUtil.java
create mode 100644
hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/transaction/TestIngestionPrimaryWriterBasedConflictResolutionStrategy.java
create mode 100644
hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/TestMultiwriterWithIngestionAsPrimaryWriter.java
