Skip to content

Commit 52936e9

Browse files
authored
[metric] fix a wrong metric calculation (#1566)
1 parent 8a93663 commit 52936e9

File tree

1 file changed

+1
-1
lines changed
  • fluss-server/src/main/java/com/alibaba/fluss/server/replica

1 file changed

+1
-1
lines changed

fluss-server/src/main/java/com/alibaba/fluss/server/replica/Replica.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -341,7 +341,7 @@ public PhysicalTablePath getPhysicalTablePath() {
341341
}
342342

343343
public boolean isAtMinIsr() {
344-
return isLeader() && isrState.isr().size() < minInSyncReplicas;
344+
return isLeader() && isrState.isr().size() == minInSyncReplicas;
345345
}
346346

347347
public BucketMetricGroup bucketMetrics() {

0 commit comments

Comments
 (0)