Add IT test case

Signed-off-by: Sean Kao <[email protected]>
opensearch-project · Apr 19, 2023 · 88bbcc1 · 88bbcc1
1 parent 6ac5d70
commit 88bbcc1
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 7 deletions.
diff --git a/integ-test/build.gradle b/integ-test/build.gradle
@@ -232,7 +232,7 @@ integTest {
             systemProperty "tests.rest.${cluster.name}.transport_hosts", "${-> allTransportSocketURI}"
         }
     }
-    
+
     testLogging {
         events "passed", "skipped", "failed"
     }

diff --git a/integ-test/src/test/java/org/opensearch/sql/ppl/CrossClusterSearchIT.java b/integ-test/src/test/java/org/opensearch/sql/ppl/CrossClusterSearchIT.java
@@ -16,8 +16,6 @@
 import java.io.IOException;
 import org.json.JSONObject;
 import org.junit.jupiter.api.Test;
-import org.opensearch.client.Request;
-import org.opensearch.client.ResponseException;
 
 public class CrossClusterSearchIT extends PPLIntegTestCase {
 
@@ -41,10 +39,17 @@ public void testCrossClusterSearchAllFields() throws IOException {
 
   @Test
   public void testCrossClusterSearchCommandWithLogicalExpression() throws IOException {
-    JSONObject result =
-        executeQuery(
-            String.format(
-                "search source=%s firstname='Hattie' | fields firstname", TEST_INDEX_BANK_REMOTE));
+    JSONObject result = executeQuery(String.format(
+        "search source=%s firstname='Hattie' | fields firstname", TEST_INDEX_BANK_REMOTE));
     verifyDataRows(result, rows("Hattie"));
   }
+
+  @Test
+  public void testCrossClusterSearchMultiClusters() throws IOException {
+    JSONObject result = executeQuery(String.format(
+        "search source=%s,%s firstname='Hattie' | fields firstname", TEST_INDEX_BANK_REMOTE, TEST_INDEX_BANK));
+    verifyDataRows(result,
+        rows("Hattie"),
+        rows("Hattie"));
+  }
 }
-Original file line number
+Diff line change
@@ Expand Up / @@ -232,7 +232,7 @@ integTest { @@
                 systemProperty "tests.rest.${cluster.name}.transport_hosts", "${-> allTransportSocketURI}"
             }
         }
         testLogging {
             events "passed", "skipped", "failed"
         }
@@ Expand Down @@