From 09e9235ecdee8debeb701d29f34978fa37fbb5e6 Mon Sep 17 00:00:00 2001
From: luoyuxia <luoyuxia@alumni.sjtu.edu.cn>
Date: Fri, 23 Jan 2026 15:10:53 +0800
Subject: [PATCH] [lake] report pending records even though no tiering is
 finished

---
 .../src/main/java/org/apache/fluss/server/replica/Replica.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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,