This is an automated email from the ASF dual-hosted git repository.
nsivabalan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from 1f20fd42e2b9 fix(flink): relocate org.apache.flink.dropwizard (#18982)
add a032431c81aa feat: add more metrics for delta streamer (#18085)
No new revisions were added by this update.
Summary of changes:
.../ingestion/HoodieIngestionMetrics.java | 4 ++
.../hudi/utilities/sources/SqlFileBasedSource.java | 6 ++-
.../apache/hudi/utilities/sources/SqlSource.java | 10 +++--
.../hudi/utilities/streamer/HoodieStreamer.java | 4 +-
.../utilities/streamer/HoodieStreamerMetrics.java | 15 +++++++
.../apache/hudi/utilities/streamer/StreamSync.java | 8 ++++
.../deltastreamer/TestHoodieDeltaStreamer.java | 16 +++++---
...estHoodieDeltaStreamerSchemaEvolutionQuick.java | 9 ++++-
.../TestHoodieDeltaStreamerWithMultiWriter.java | 5 ++-
.../multisync/TestMultipleMetaSync.java | 13 +++---
.../utilities/sources/TestSqlFileBasedSource.java | 13 +++---
.../hudi/utilities/sources/TestSqlSource.java | 15 ++++---
.../TestStreamerSourceCheckpointVersion.java | 2 +-
.../TestHoodieIncrSourceE2EAutoUpgrade.java | 7 +++-
.../streamer/TestHoodieStreamerMetrics.java | 47 ++++++++++++++++++++++
.../hudi/utilities/streamer/TestStreamSync.java | 33 +++++++++++++++
16 files changed, 173 insertions(+), 34 deletions(-)
