diff --git a/fluss-server/src/main/java/org/apache/fluss/server/replica/Replica.java b/fluss-server/src/main/java/org/apache/fluss/server/replica/Replica.java index 7a2003786c..9314901fea 100644 --- a/fluss-server/src/main/java/org/apache/fluss/server/replica/Replica.java +++ b/fluss-server/src/main/java/org/apache/fluss/server/replica/Replica.java @@ -535,7 +535,7 @@ private void registerLakeTieringMetrics() { MetricNames.LOG_LAKE_PENDING_RECORDS, () -> getLakeLogEndOffset() < 0L - ? -1 + ? getLogHighWatermark() - getLogStartOffset() : getLogHighWatermark() - getLakeLogEndOffset()); lakeTieringMetricGroup.gauge( MetricNames.LOG_LAKE_TIMESTAMP_LAG,