use static max heap threshold 100

Signed-off-by: Xun Zhang <[email protected]>
opensearch-project · Jul 16, 2024 · d14443d · d14443d
1 parent 0d89332
commit d14443d
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/plugin/src/main/java/org/opensearch/ml/breaker/MemoryCircuitBreaker.java b/plugin/src/main/java/org/opensearch/ml/breaker/MemoryCircuitBreaker.java
@@ -18,6 +18,7 @@ public class MemoryCircuitBreaker extends ThresholdCircuitBreaker<Short> {
     // TODO: make this value configurable as cluster setting
     private static final String ML_MEMORY_CB = "Memory Circuit Breaker";
     public static final short DEFAULT_JVM_HEAP_USAGE_THRESHOLD = 85;
+    public static final short JVM_HEAP_MAX_THRESHOLD = 100; // when threshold is 100, this CB check is ignored
     private final JvmService jvmService;
     private volatile Integer jvmHeapMemThreshold = 85;
 
@@ -50,6 +51,6 @@ public Short getThreshold() {
 
     @Override
     public boolean isOpen() {
-        return getThreshold() < 100 && jvmService.stats().getMem().getHeapUsedPercent() > getThreshold();
+        return getThreshold() < JVM_HEAP_MAX_THRESHOLD && jvmService.stats().getMem().getHeapUsedPercent() > getThreshold();
     }
 }