This is an automated email from the ASF dual-hosted git repository.
yuxia pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git
from 2df0914bd [client][backport] Skip blocked bucket instead of stopping
drain loop in idempotent writer (#2953)
add f45f41bcb [lake/tiering] add total bytes read tracking and metrics for
tiering service (#2933)
No new revisions were added by this update.
Summary of changes:
.../fluss/client/table/scanner/ScanRecord.java | 18 +++++
.../client/table/scanner/log/CompletedFetch.java | 31 ++++++++-
.../table/scanner/log/LogFetchCollector.java | 4 +-
.../fluss/client/table/scanner/log/LogFetcher.java | 3 +-
.../client/table/scanner/log/LogScannerImpl.java | 21 +++---
.../table/scanner/log/LogFetchCollectorTest.java | 68 ++++++++++++++++---
.../client/table/scanner/log/LogFetcherITCase.java | 26 ++++----
.../java/org/apache/fluss/metrics/MetricNames.java | 8 +++
.../java/org/apache/fluss/row/ProjectedRow.java | 10 +++
.../flink/source/reader/BoundedSplitReader.java | 13 +++-
.../flink/tiering/source/TieringSourceReader.java | 25 +++++--
.../flink/tiering/source/TieringSplitReader.java | 20 +++++-
.../tiering/source/metrics/TieringMetrics.java | 67 +++++++++++++++++++
.../source/reader/BoundedSplitReaderTest.java | 76 ++++++++++++++++++++++
.../flink/tiering/source/TieringMetricsTest.java | 53 +++++++++++++++
.../tiering/source/TieringSplitReaderTest.java | 10 ++-
.../maintenance/observability/monitor-metrics.md | 32 ++++++++-
17 files changed, 434 insertions(+), 51 deletions(-)
create mode 100644
fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/tiering/source/metrics/TieringMetrics.java
create mode 100644
fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/tiering/source/TieringMetricsTest.java
