(fluss) branch main updated: [lake] report pending records even though no tiering is finished (#2453)

[yuxia]

This is an automated email from the ASF dual-hosted git repository.

yuxia pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git


The following commit(s) were added to refs/heads/main by this push:
     new 69258dcd7 [lake] report pending records even though no tiering is 
finished (#2453)
69258dcd7 is described below

commit 69258dcd7d0e43884776a35eddce63075c5629fa
Author: yuxia Luo <luoyu...@alumni.sjtu.edu.cn>
AuthorDate: Fri Jan 23 15:57:25 2026 +0800

    [lake] report pending records even though no tiering is finished (#2453)
---
 fluss-server/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 7a2003786..9314901fe 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 @@ public final class Replica {
                 MetricNames.LOG_LAKE_PENDING_RECORDS,
                 () ->
                         getLakeLogEndOffset() < 0L
-                                ? -1
+                                ? getLogHighWatermark() - getLogStartOffset()
                                 : getLogHighWatermark() - 
getLakeLogEndOffset());
         lakeTieringMetricGroup.gauge(
                 MetricNames.LOG_LAKE_TIMESTAMP_LAG,