This is an automated email from the ASF dual-hosted git repository.
xushiyan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from 51a0e81e831a fix: correct unsigned int conversion in
TestProtoConversionUtil (#18120)
add 1ae0d5e9ac97 feat: add flink stream read metrics for hudi source v2
(#18130)
No new revisions were added by this update.
Summary of changes:
.../hudi/metrics/FlinkStreamReadMetrics.java | 4 +--
.../java/org/apache/hudi/source/HoodieSource.java | 13 +++++---
.../hudi/source/StreamReadMonitoringFunction.java | 9 ++++-
.../org/apache/hudi/source/StreamReadOperator.java | 2 +-
.../enumerator/AbstractHoodieSplitEnumerator.java | 10 +++++-
.../HoodieContinuousSplitEnumerator.java | 4 ++-
.../enumerator/HoodieStaticSplitEnumerator.java | 4 +--
.../hudi/source/reader/HoodieSourceReader.java | 4 +--
.../source/reader/HoodieSourceSplitReader.java | 8 +++++
.../org/apache/hudi/table/HoodieTableSource.java | 1 +
.../table/format/mor/MergeOnReadInputFormat.java | 7 ++++
.../TestHoodieContinuousSplitEnumerator.java | 29 ++++++++++-------
.../TestHoodieStaticSplitEnumerator.java | 2 +-
.../source/reader/TestHoodieSourceSplitReader.java | 38 +++++++++++-----------
.../test/java/org/apache/hudi/utils/TestUtils.java | 3 +-
15 files changed, 90 insertions(+), 48 deletions(-)
