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 422f510ebd4 [HUDI-8882] Support Compaction/Rollback/Clean Timeline
Instant Metrics in HoodieMetrics (#12681)
add 258ed5a09e0 [HUDI-8126] Persist sourceRdd to optimise writeStatus DAG
for error table (#11844)
No new revisions were added by this update.
Summary of changes:
.../apache/hudi/config/HoodieErrorTableConfig.java | 4 +
.../org/apache/hudi/config/HoodieWriteConfig.java | 5 +
.../commit/BaseSparkCommitActionExecutor.java | 4 +-
.../utilities/callback/SourceCommitCallback.java | 6 ++
.../org/apache/hudi/utilities/sources/Source.java | 37 +++++++
.../utilities/streamer/SourceFormatAdapter.java | 1 +
.../apache/hudi/utilities/streamer/StreamSync.java | 112 +++++++++++----------
.../deltastreamer/TestHoodieDeltaStreamer.java | 72 ++++++++++++-
.../utilities/sources/BaseTestKafkaSource.java | 13 +++
.../utilities/sources/TestJsonKafkaSource.java | 27 +++--
.../utilities/sources/TestProtoKafkaSource.java | 14 ++-
.../hudi/utilities/sources/TestS3EventsSource.java | 41 ++++++--
.../AbstractCloudObjectsSourceTestBase.java | 3 +-
13 files changed, 261 insertions(+), 78 deletions(-)
