Fix a bug in Search Backpressure

Signed-off-by: PritLadani <pritkladani@gmail.com>
opensearch-project · Feb 23, 2023 · 7e76ecd · 7e76ecd
1 parent 01466a6
commit 7e76ecd
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/server/src/main/java/org/opensearch/search/backpressure/trackers/HeapUsageTracker.java b/server/src/main/java/org/opensearch/search/backpressure/trackers/HeapUsageTracker.java
@@ -107,7 +107,7 @@ public static boolean isHeapTrackingSupported() {
      */
     public static boolean isHeapUsageDominatedBySearch(List<CancellableTask> cancellableTasks, double heapPercentThreshold) {
         long usage = cancellableTasks.stream().mapToLong(task -> task.getTotalResourceStats().getMemoryInBytes()).sum();
-        long threshold = (long) heapPercentThreshold * HEAP_SIZE_BYTES;
+        long threshold = (long) (heapPercentThreshold * HEAP_SIZE_BYTES);
         if (isHeapTrackingSupported() && usage < threshold) {
             logger.debug("heap usage not dominated by search requests [{}/{}]", usage, threshold);
             return false;