Fix AbstractTasksIT

Signed-off-by: Sachin Kale <kalsac@amazon.com>
soosinha · Sep 2, 2023 · 907ca18 · 907ca18
1 parent 268e711
commit 907ca18
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/...ernalClusterTest/java/org/opensearch/action/admin/cluster/node/tasks/AbstractTasksIT.java b/...ernalClusterTest/java/org/opensearch/action/admin/cluster/node/tasks/AbstractTasksIT.java
@@ -60,18 +60,18 @@ protected Settings nodeSettings(int nodeOrdinal) {
         return Settings.builder()
             .put(super.nodeSettings(nodeOrdinal))
             .put(MockTaskManager.USE_MOCK_TASK_MANAGER_SETTING.getKey(), true)
-            .put(remoteStoreGlobalClusterSettings(REPOSITORY_NAME, REPOSITORY_2_NAME))
+            //.put(remoteStoreGlobalClusterSettings(REPOSITORY_NAME, REPOSITORY_2_NAME))
             .build();
     }
 
     @Override
     public void tearDown() throws Exception {
-        for (Map.Entry<Tuple<String, String>, RecordingTaskManagerListener> entry : listeners.entrySet()) {
-            ((MockTaskManager) internalCluster().getInstance(TransportService.class, entry.getKey().v1()).getTaskManager()).removeListener(
-                entry.getValue()
-            );
-        }
-        listeners.clear();
+//        for (Map.Entry<Tuple<String, String>, RecordingTaskManagerListener> entry : listeners.entrySet()) {
+//            ((MockTaskManager) internalCluster().getInstance(TransportService.class, entry.getKey().v1()).getTaskManager()).removeListener(
+//                entry.getValue()
+//            );
+//        }
+//        listeners.clear();
         super.tearDown();
     }