cleanup

Signed-off-by: Jackie Han <[email protected]>
opensearch-project · Jan 29, 2025 · 64cc3bc · 64cc3bc
1 parent 05f56a3
commit 64cc3bc
Showing 1 changed file with 15 additions and 21 deletions.
diff --git a/src/test/java/org/opensearch/ad/rest/AnomalyDetectorRestApiIT.java b/src/test/java/org/opensearch/ad/rest/AnomalyDetectorRestApiIT.java
@@ -246,27 +246,21 @@ public void testCreateAnomalyDetector_withFlattenedResultIndex() throws Exceptio
 
         Map<String, Object> searchResults = null;
         for (int attempt = 0; attempt < maxRetries; attempt++) {
-            try {
-                Response searchAllResponse = TestHelpers
-                    .makeRequest(
-                        client(),
-                        "POST",
-                        TestHelpers.AD_BASE_RESULT_URI + "/_search/" + expectedFlattenedIndex,
-                        ImmutableMap.of(),
-                        new StringEntity("{\"query\":{\"match_all\":{}}}", ContentType.APPLICATION_JSON),
-                        null
-                    );
-                searchResults = entityAsMap(searchAllResponse);
-                List<Map<String, Object>> hitsList = (List<Map<String, Object>>) ((Map<String, Object>) searchResults.get("hits"))
-                    .get("hits");
-
-                if (hitsList != null && !hitsList.isEmpty()) {
-                    resultsAvailable = true;
-                    break;
-                }
-            } catch (Exception e) {
-                // Log the retry attempt and continue retrying
-                System.out.println("Attempt " + (attempt + 1) + " failed, retrying...");
+            Response searchAllResponse = TestHelpers
+                .makeRequest(
+                    client(),
+                    "POST",
+                    TestHelpers.AD_BASE_RESULT_URI + "/_search/" + expectedFlattenedIndex,
+                    ImmutableMap.of(),
+                    new StringEntity("{\"query\":{\"match_all\":{}}}", ContentType.APPLICATION_JSON),
+                    null
+                );
+            searchResults = entityAsMap(searchAllResponse);
+            List<Map<String, Object>> hitsList = (List<Map<String, Object>>) ((Map<String, Object>) searchResults.get("hits")).get("hits");
+
+            if (hitsList != null && !hitsList.isEmpty()) {
+                resultsAvailable = true;
+                break;
             }
             Thread.sleep(retryIntervalMs);
         }