From d8c31eecc1f92377f038293803fe2f122fba9f33 Mon Sep 17 00:00:00 2001
From: Kiran Prakash <awskiran@amazon.com>
Date: Fri, 30 Aug 2024 07:59:06 +0530
Subject: [PATCH] Update QueryGroupService.java

Signed-off-by: Kiran Prakash <awskiran@amazon.com>
---
 .../org/opensearch/wlm/QueryGroupService.java   | 17 ++++-------------
 1 file changed, 4 insertions(+), 13 deletions(-)

diff --git a/server/src/main/java/org/opensearch/wlm/QueryGroupService.java b/server/src/main/java/org/opensearch/wlm/QueryGroupService.java
index bb9659e60551f..87f40f52ac10c 100644
--- a/server/src/main/java/org/opensearch/wlm/QueryGroupService.java
+++ b/server/src/main/java/org/opensearch/wlm/QueryGroupService.java
@@ -17,22 +17,13 @@
 import org.opensearch.cluster.service.ClusterService;
 import org.opensearch.common.inject.Inject;
 import org.opensearch.common.lifecycle.AbstractLifecycleComponent;
-import org.opensearch.common.settings.ClusterSettings;
-import org.opensearch.common.settings.Settings;
-import org.opensearch.common.unit.TimeValue;
-import org.opensearch.monitor.jvm.JvmStats;
-import org.opensearch.monitor.process.ProcessProbe;
-import org.opensearch.search.ResourceType;
-import org.opensearch.search.backpressure.settings.NodeDuressSettings;
-import org.opensearch.search.backpressure.trackers.NodeDuressTrackers;
+import org.opensearch.threadpool.Scheduler;
+import org.opensearch.threadpool.ThreadPool;
 import org.opensearch.wlm.cancellation.DefaultTaskCancellation;
 import org.opensearch.wlm.cancellation.DefaultTaskSelectionStrategy;
 import org.opensearch.wlm.tracker.QueryGroupResourceUsageTrackerService;
-import org.opensearch.threadpool.Scheduler;
-import org.opensearch.threadpool.ThreadPool;
 
 import java.io.IOException;
-import java.util.EnumMap;
 import java.util.HashSet;
 import java.util.Map;
 import java.util.Set;
@@ -92,7 +83,7 @@ protected void doRun() {
      */
     @Override
     protected void doStart() {
-        if(!workloadManagementSettings.queryGroupServiceEnabled()) {
+        if (!workloadManagementSettings.queryGroupServiceEnabled()) {
             return;
         }
         scheduledFuture = threadPool.scheduleWithFixedDelay(() -> {
@@ -106,7 +97,7 @@ protected void doStart() {
 
     @Override
     protected void doStop() {
-        if(workloadManagementSettings.queryGroupServiceEnabled()) {
+        if (workloadManagementSettings.queryGroupServiceEnabled()) {
             return;
         }
         if (scheduledFuture != null) {