correct exception

Signed-off-by: Aparajita Pandey <aparajita31pandey@gmail.com>

Author: aparajita31pandey

integ-test/src/test/java/org/opensearch/sql/sql/PaginationIT.java

@@ -6,7 +6,8 @@
 package org.opensearch.sql.sql;
 
 import static org.opensearch.sql.legacy.TestUtils.getResponseBody;
-import static org.opensearch.sql.legacy.TestsConstants.*;
+import static org.opensearch.sql.legacy.TestsConstants.TEST_INDEX_CALCS;
+import static org.opensearch.sql.legacy.TestsConstants.TEST_INDEX_ONLINE;
 
 import java.io.IOException;
 import lombok.SneakyThrows;
@@ -256,22 +257,24 @@ public void testAlias() throws Exception {
   public void testAliasResultConsistency() throws Exception {
     String aliasName = "alias_dog_consistency";
 
-    // Create an alias for 2 index(dog1, dog2)
+    // Create an alias that maps to both DOG and DOGS2 indices
     String createAliasQuery =
         String.format(
-            "{ \"actions\": [ { \"add\": { \"index\": \"%s\", \"alias\": \"%s\" } }, "
-                + "{\"add\": { \"index\": \"%s\", \"alias\": \"%s\" } } ] }",
+            "{ \"actions\": [ "
+                + "{ \"add\": { \"index\": \"%s\", \"alias\": \"%s\" } }, "
+                + "{ \"add\": { \"index\": \"%s\", \"alias\": \"%s\" } } "
+                + "] }",
             Index.DOG.getName(), aliasName, Index.DOGS2.getName(), aliasName);
     Request createAliasRequest = new Request("POST", "/_aliases");
     createAliasRequest.setJsonEntity(createAliasQuery);
     JSONObject aliasResponse = new JSONObject(executeRequest(createAliasRequest));
     assertTrue(aliasResponse.getBoolean("acknowledged"));
 
-    // Query using direct index
-    String directQuery = String.format("SELECT * FROM %s", TEST_INDEX_DOG);
+    // Query both indices directly (same indices the alias points to)
+    String directQuery = String.format("SELECT * FROM %s, %s", Index.DOG.getName(), Index.DOGS2.getName());
     JSONObject directResponse = new JSONObject(executeFetchQuery(directQuery, 10, "jdbc"));
 
-    // Query using alias
+    // Query using alias (which points to the same two indices)
     String aliasQuery = String.format("SELECT * FROM %s", aliasName);
     JSONObject aliasQueryResponse = new JSONObject(executeFetchQuery(aliasQuery, 10, "jdbc"));
 

legacy/src/main/java/org/opensearch/sql/legacy/executor/format/SelectResultSet.java

@@ -175,7 +175,7 @@ private void loadFromEsState(Query query) {
     Map<String, Map<String, FieldMappingMetadata>> mappings = response.mappings();
     if (mappings.isEmpty()) {
       throw new IllegalArgumentException(
-          String.format(String.format("Index type %s does not exist", query.getFrom())));
+          String.format("Index type %s does not exist", query.getFrom()));
     }
     Map<String, FieldMappingMetadata> typeMappings = mappings.values().iterator().next();