Fix: delete test doc with refresh

yuancu · yuancu · commit 37676ff26ee5 · 2025-06-08T12:26:51.000+08:00
Signed-off-by: Yuanchun Shen &lt;yuanchu@amazon.com&gt;
diff --git a/integ-test/src/test/java/org/opensearch/sql/calcite/remote/CalciteExpandCommandIT.java b/integ-test/src/test/java/org/opensearch/sql/calcite/remote/CalciteExpandCommandIT.java
@@ -395,7 +395,8 @@ public void testExpandEmptyArray() throws Exception {
 
     verifyNumOfRows(response, 12);
     Request deleteRequest =
-        new Request("DELETE", String.format("/%s/_doc/%d", TEST_INDEX_NESTED_SIMPLE, docId));
+        new Request(
+            "DELETE", String.format("/%s/_doc/%d?refresh=true", TEST_INDEX_NESTED_SIMPLE, docId));
     client().performRequest(deleteRequest);
   }
 }

Original file line number	Diff line number	Diff line change
`@@ -395,7 +395,8 @@ public void testExpandEmptyArray() throws Exception {`
`395`	`395`
`396`	`396`	`verifyNumOfRows(response, 12);`
`397`	`397`	`Request deleteRequest =`
`398`		`- new Request("DELETE", String.format("/%s/_doc/%d", TEST_INDEX_NESTED_SIMPLE, docId));`
	`398`	`+ new Request(`
	`399`	`+ "DELETE", String.format("/%s/_doc/%d?refresh=true", TEST_INDEX_NESTED_SIMPLE, docId));`
`399`	`400`	`client().performRequest(deleteRequest);`
`400`	`401`	`}`
`401`	`402`	`}`