From 36a5932b9e76093542a1bcb0e63139caadfb5b71 Mon Sep 17 00:00:00 2001 From: "whenzhou.zc" Date: Tue, 19 Aug 2025 20:23:34 +0800 Subject: [PATCH] [metric] fix a wrong metric calculation --- .../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 0e8a6d8952..38e0642d99 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 PhysicalTablePath getPhysicalTablePath() { } public boolean isAtMinIsr() { - return isLeader() && isrState.isr().size() < minInSyncReplicas; + return isLeader() && isrState.isr().size() == minInSyncReplicas; } public BucketMetricGroup bucketMetrics() {