Skip to content

Commit a0be241

Browse files
committed
Fix IT
Signed-off-by: Lantao Jin <ltjin@amazon.com>
1 parent 34d0aea commit a0be241

1 file changed

Lines changed: 11 additions & 5 deletions

File tree

integ-test/src/test/java/org/opensearch/sql/security/CalciteCrossClusterSearchIT.java

Lines changed: 11 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,7 @@ public void testCrossClusterFieldsWildcardSuffix() throws IOException {
8888
JSONObject result =
8989
executeQuery(String.format("search source=%s | fields *Name", TEST_INDEX_DOG_REMOTE));
9090
verifyColumn(result, columnName("dog_name"), columnName("holdersName"));
91-
verifySchema(result, schema("dog_name", "string"), schema("holdersName", "string"));
91+
verifySchema(result, schema("holdersName", "string"));
9292
}
9393

9494
@Test
@@ -165,7 +165,7 @@ public void testDefaultBinCrossCluster() throws IOException {
165165
TEST_INDEX_ACCOUNT_REMOTE));
166166
verifySchema(result, schema("count()", null, "bigint"), schema("age", null, "string"));
167167

168-
verifyDataRows(result, rows(451L, "20-30"), rows(504L, "30-40"), rows(45L, "40-50"));
168+
verifyDataRows(result, rows(451, "20.0-30.0"), rows(504L, "30.0-40.0"), rows(45L, "40.0-50.0"));
169169
}
170170

171171
@Test
@@ -218,7 +218,7 @@ public void testRangeBinCrossCluster() throws IOException {
218218
TEST_INDEX_ACCOUNT_REMOTE));
219219
verifySchema(result, schema("count()", null, "bigint"), schema("age", null, "string"));
220220

221-
verifyDataRows(result, rows(1000L, "0-100"));
221+
verifyDataRows(result, rows(451, "20-30"), rows(504L, "30-40"), rows(45L, "40-50"));
222222
}
223223

224224
@Test
@@ -227,7 +227,7 @@ public void testTimeBinCrossCluster() throws IOException {
227227
JSONObject result =
228228
executeQuery(
229229
REMOTE_CLUSTER
230-
+ ":opensearch-sql_test_index_time_data"
230+
+ "source=opensearch-sql_test_index_time_data"
231231
+ " | bin @timestamp span=1h"
232232
+ " | fields `@timestamp`, value | sort `@timestamp` | head 3");
233233
verifySchema(result, schema("@timestamp", null, "timestamp"), schema("value", null, "int"));
@@ -290,7 +290,13 @@ public void testCrossClusterRenameFullWildcard() throws IOException {
290290
result,
291291
schema("old_dog_name", "string"),
292292
schema("old_holdersName", "string"),
293-
schema("old_age", "bigint"));
293+
schema("old_age", "bigint"),
294+
schema("old__id", "bigint"),
295+
schema("old__index", "bigint"),
296+
schema("old__score", "bigint"),
297+
schema("old__maxscore", "bigint"),
298+
schema("old__sort", "bigint"),
299+
schema("old__routing", "bigint"));
294300
}
295301

296302
@Test

0 commit comments

Comments
 (0)