You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by si...@apache.org on 2021/08/14 12:19:05 UTC
[hudi] branch master updated (b7da6cb -> 9056c68)
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 b7da6cb [HUDI-2307] When using delete_partition with ds should not rely on the primary key (#3469)
add 9056c68 [HUDI-2305] Add MARKERS.type and fix marker-based rollback (#3472)
No new revisions were added by this update.
Summary of changes:
.../client/embedded/EmbeddedTimelineService.java | 4 +-
.../org/apache/hudi/config/HoodieWriteConfig.java | 4 +-
.../hudi/table/marker/DirectWriteMarkers.java | 5 +-
.../table/marker/MarkerBasedRollbackUtils.java | 78 ++++++++
.../org/apache/hudi/table/marker/MarkerType.java | 27 ---
.../org/apache/hudi/table/marker/WriteMarkers.java | 18 --
.../hudi/table/marker/WriteMarkersFactory.java | 1 +
.../rollback/FlinkMarkerBasedRollbackStrategy.java | 8 +-
.../table/upgrade/ZeroToOneUpgradeHandler.java | 4 +-
.../rollback/JavaMarkerBasedRollbackStrategy.java | 9 +-
.../rollback/SparkMarkerBasedRollbackStrategy.java | 11 +-
.../table/upgrade/ZeroToOneUpgradeHandler.java | 8 +-
.../TestTimelineServerBasedWriteMarkers.java | 41 ++--
.../hudi/table/marker/TestWriteMarkersBase.java | 11 +-
.../IOType.java => table/marker/MarkerType.java} | 11 +-
.../org/apache/hudi/common/util/MarkerUtils.java | 219 +++++++++++++++++++++
.../timeline/service/handlers/MarkerHandler.java | 2 +-
.../service/handlers/marker/MarkerDirState.java | 106 +++++-----
18 files changed, 399 insertions(+), 168 deletions(-)
create mode 100644 hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/marker/MarkerBasedRollbackUtils.java
delete mode 100644 hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/marker/MarkerType.java
copy hudi-common/src/main/java/org/apache/hudi/common/{model/IOType.java => table/marker/MarkerType.java} (82%)
create mode 100644 hudi-common/src/main/java/org/apache/hudi/common/util/MarkerUtils.java