(fluss) branch main updated: [metric] fix a wrong metric calculation (#1566)

[yu...@apache.org]

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 52936e9c2 [metric] fix a wrong metric calculation (#1566)
52936e9c2 is described below

commit 52936e9c21a22ece50cbc1d6d51127054bf22670
Author: xiaozhou <wh...@alibaba-inc.com>
AuthorDate: Tue Aug 19 21:19:07 2025 +0800

    [metric] fix a wrong metric calculation (#1566)
---
 .../src/main/java/com/alibaba/fluss/server/replica/Replica.java         | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/fluss-server/src/main/java/com/alibaba/fluss/server/replica/Replica.java b/fluss-server/src/main/java/com/alibaba/fluss/server/replica/Replica.java
index 0e8a6d895..38e0642d9 100644
--- a/fluss-server/src/main/java/com/alibaba/fluss/server/replica/Replica.java
+++ b/fluss-server/src/main/java/com/alibaba/fluss/server/replica/Replica.java
@@ -341,7 +341,7 @@ public final class Replica {
     }
 
     public boolean isAtMinIsr() {
-        return isLeader() && isrState.isr().size() < minInSyncReplicas;
+        return isLeader() && isrState.isr().size() == minInSyncReplicas;
     }
 
     public BucketMetricGroup bucketMetrics() {