Add Watermark Metrics in Flink Runner
Open
flink
P3
runners
sub-task
- Dominant language
- Java
- Stars
- 8.7k
- Forks
- 4.7k
- Avg merge
- 1d 20h
- Merged PRs (30d)
- 196
Description
Imported from Jira [BEAM-1942](https://issues.apache.org/jira/browse/BEAM-1942). Original Jira may contain additional context.
Reported by: lzljs3620320.
Subtask of issue #18359
Contributor guide
Research direction
Start with parent issue #18359 and imported Jira BEAM-1942, which may contain the missing context. No files, tests, or implementation entry points are named here; trace the Flink Runner's metrics area and consider the work complete when watermark metrics are added and verified by the relevant tests.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- java
- Domain
- observability-sre, stream-processing
- Issue type
- Feature
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 25/100