Drop threshold further

Signed-off-by: Stephen Crawford <steecraw@amazon.com>
opensearch-project · Jun 9, 2023 · c867646 · c867646
1 parent a778c69
commit c867646
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/...src/internalClusterTest/java/org/opensearch/search/backpressure/SearchBackpressureIT.java b/...src/internalClusterTest/java/org/opensearch/search/backpressure/SearchBackpressureIT.java
@@ -151,7 +151,7 @@ public void testSearchShardTaskCancellationWithHighElapsedTime() throws Interrup
     public void testSearchTaskCancellationWithHighCpu() throws InterruptedException {
         Settings request = Settings.builder()
             .put(SearchBackpressureSettings.SETTING_MODE.getKey(), "enforced")
-            .put(SearchTaskSettings.SETTING_CPU_TIME_MILLIS_THRESHOLD.getKey(), 500)
+            .put(SearchTaskSettings.SETTING_CPU_TIME_MILLIS_THRESHOLD.getKey(), 50)
             .build();
         assertAcked(client().admin().cluster().prepareUpdateSettings().setPersistentSettings(request).get());
 

diff --git a/server/src/main/java/org/opensearch/search/backpressure/trackers/CpuUsageTracker.java b/server/src/main/java/org/opensearch/search/backpressure/trackers/CpuUsageTracker.java
@@ -48,6 +48,7 @@ public Optional<TaskCancellation.Reason> checkAndMaybeGetCancellationReason(Task
         long threshold = thresholdSupplier.getAsLong();
 
         if (usage < threshold) {
+
             return Optional.empty();
         }
-Original file line number
+Diff line change
@@ Expand Up @@
             long threshold = thresholdSupplier.getAsLong();
             if (usage < threshold) {
                 return Optional.empty();
             }
@@ Expand Down @@