Skip to content

feat: add flink stream read metrics for hudi source v2#18130

Merged
xushiyan merged 1 commit intoapache:masterfrom
HuangZhenQiu:source-v2-metrics
Feb 10, 2026
Merged

feat: add flink stream read metrics for hudi source v2#18130
xushiyan merged 1 commit intoapache:masterfrom
HuangZhenQiu:source-v2-metrics

Conversation

@HuangZhenQiu
Copy link
Copy Markdown
Collaborator

@HuangZhenQiu HuangZhenQiu commented Feb 8, 2026 •
edited
Loading

Describe the issue this Pull Request addresses

Integrate FlinkStreamReadMetrics into Hudi Flink Source V2

Closes #18129

Summary and Changelog

  1. Table name as parameter for FlinkStreamReadMetrics to track reading from multiple tables.
  2. Integrate FlinkStreamReadMetrics in HoodieSourceSplitReader to track split latest commit
  3. Integrate FlinkStreamReadMetrics in HoodieContinuousSplitEnumerator to track issued instant

Impact

none

Risk Level

none

Documentation Update

none

Contributor's checklist

  • Read through contributor's guide
  • Enough context is provided in the sections above
  • Adequate tests were added if applicable

@HuangZhenQiu HuangZhenQiu requested a review from xushiyan February 8, 2026 01:02
@github-actions github-actions Bot added the size:S PR with lines of changes in (10, 100] label Feb 8, 2026
xushiyan
xushiyan reviewed Feb 8, 2026
View reviewed changes
Comment thread ...tasource/hudi-flink/src/main/java/org/apache/hudi/source/reader/HoodieSourceSplitReader.java Outdated
Comment thread ...i-flink/src/main/java/org/apache/hudi/source/enumerator/HoodieContinuousSplitEnumerator.java Outdated
Comment thread ...i-flink/src/main/java/org/apache/hudi/source/enumerator/HoodieContinuousSplitEnumerator.java Outdated
Comment thread hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/HoodieSource.java Outdated
cshuo
cshuo reviewed Feb 9, 2026
View reviewed changes
Comment thread hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/HoodieSource.java Outdated
@HuangZhenQiu HuangZhenQiu force-pushed the source-v2-metrics branch 2 times, most recently from c62b29a to c29e29e Compare February 9, 2026 20:51
@github-actions github-actions Bot added size:M PR with lines of changes in (100, 300] and removed size:S PR with lines of changes in (10, 100] labels Feb 9, 2026
@apache apache deleted a comment from hudi-bot Feb 9, 2026
@hudi-bot
Copy link
Copy Markdown
Collaborator

hudi-bot commented Feb 10, 2026

CI report:

Bot commands @hudi-bot supports the following commands:
  • @hudi-bot run azure re-run the last Azure build

@xushiyan
Copy link
Copy Markdown
Member

xushiyan commented Feb 10, 2026

CI passed: https://dev.azure.com/apachehudi/hudi-oss-ci/_build/results?buildId=11849&view=results

@xushiyan xushiyan merged commit 1ae0d5e into apache:master Feb 10, 2026
71 of 72 checks passed
dwshmilyss pushed a commit to dwshmilyss/hudi that referenced this pull request Mar 11, 2026
@HuangZhenQiu
feat: add flink stream read metrics for hudi source v2 (apache#18130)
698f980
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Reviewers

@xushiyan xushiyan xushiyan approved these changes

+1 more reviewer

@cshuo cshuo cshuo left review comments

Reviewers whose approvals may not affect merge requirements

Assignees

No one assigned

Labels

size:M PR with lines of changes in (100, 300]

Projects

None yet

Milestone

No milestone

Development

Successfully merging this pull request may close these issues.

Integrate with Flink Read Metrics

4 participants

@HuangZhenQiu @hudi-bot @xushiyan @cshuo