(fluss) branch main updated: [hotfix] add tableBucket info for the print log while shrinking isr (#1704)

[yunhong]

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

yunhong 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 7f3b26670 [hotfix] add tableBucket info for the print log while 
shrinking isr (#1704)
7f3b26670 is described below

commit 7f3b26670a6be72ff697c43f0655545ebbfedb0a
Author: yunhong <337361...@qq.com>
AuthorDate: Tue Sep 16 14:28:00 2025 +0800

    [hotfix] add tableBucket info for the print log while shrinking isr (#1704)
---
 .../src/main/java/org/apache/fluss/server/replica/Replica.java         | 3 ++-
 1 file changed, 2 insertions(+), 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 feb657201..44e44bfe6 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
@@ -1420,10 +1420,11 @@ public final class Replica {
                                                 new 
ArrayList<>(currentIstState.isr());
                                         
newIsr.removeAll(outOfSyncFollowerReplicas);
                                         LOG.info(
-                                                "Shrink ISR From {} to {}. 
Leader: (high watermark: {}, "
+                                                "Shrink ISR From {} to {} for 
bucket {}. Leader: (high watermark: {}, "
                                                         + "end offset: {}, out 
of sync replicas: {})",
                                                 currentIstState.isr(),
                                                 newIsr,
+                                                tableBucket,
                                                 logTablet.getHighWatermark(),
                                                 logTablet.localLogEndOffset(),
                                                 outOfSyncFollowerReplicas);