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 5a13ce10535 [HUDI-8468] use payload to do merging inside the
expression payload (#12726)
add 0a0f3bbea26 [HUDI-8917] Checkpoint reset handling (#12718)
No new revisions were added by this update.
Summary of changes:
.../hudi/table/upgrade/UpgradeDowngrade.java | 6 +-
.../hudi/common/table/checkpoint/Checkpoint.java | 5 +
.../common/table/checkpoint/CheckpointUtils.java | 24 ++
.../HoodieIncrSourceCheckpointValUtils.java | 71 +++++
.../UnresolvedStreamerCheckpointBasedOnCfg.java | 49 ++++
.../table/checkpoint/TestCheckpointUtils.java | 51 +++-
.../TestHoodieIncrSourceCheckpointValUtils.java | 80 ++++++
.../hudi/utilities/sources/HoodieIncrSource.java | 12 +-
.../org/apache/hudi/utilities/sources/Source.java | 34 ++-
.../hudi/utilities/streamer/HoodieStreamer.java | 7 +-
.../apache/hudi/utilities/streamer/StreamSync.java | 12 +-
.../streamer/StreamerCheckpointUtils.java | 107 +++++--
.../utilities/sources/CheckpointValidator.java | 48 +++-
.../utilities/sources/DummyOperationExecutor.java | 32 ++-
...ource.java => MockGeneralHoodieIncrSource.java} | 36 +--
...kpVersion.java => TestHoodieIncrSourceE2E.java} | 110 +++++++-
.../TestHoodieIncrSourceE2EAutoUpgrade.java | 312 +++++++++++++++++++++
.../streamer/TestStreamerCheckpointUtils.java | 168 +++++++++--
18 files changed, 1048 insertions(+), 116 deletions(-)
create mode 100644
hudi-common/src/main/java/org/apache/hudi/common/table/checkpoint/HoodieIncrSourceCheckpointValUtils.java
create mode 100644
hudi-common/src/main/java/org/apache/hudi/common/table/checkpoint/UnresolvedStreamerCheckpointBasedOnCfg.java
create mode 100644
hudi-common/src/test/java/org/apache/hudi/common/table/checkpoint/TestHoodieIncrSourceCheckpointValUtils.java
copy
hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/{MockGcsEventsHoodieIncrSource.java
=> MockGeneralHoodieIncrSource.java} (67%)
rename
hudi-utilities/src/test/java/org/apache/hudi/utilities/streamer/{TestS3GcsEventsHoodieIncrSourceE2ECkpVersion.java
=> TestHoodieIncrSourceE2E.java} (80%)
create mode 100644
hudi-utilities/src/test/java/org/apache/hudi/utilities/streamer/TestHoodieIncrSourceE2EAutoUpgrade.java
