includeMetadata

dnhatn · dnhatn · commit 6c4ec5afdabd · 2025-02-18T09:39:46.000-08:00
diff --git a/x-pack/plugin/esql/src/internalClusterTest/java/org/elasticsearch/xpack/esql/action/CrossClusterQueryWithPartialResultsIT.java b/x-pack/plugin/esql/src/internalClusterTest/java/org/elasticsearch/xpack/esql/action/CrossClusterQueryWithPartialResultsIT.java
@@ -71,12 +71,10 @@ public void testPartialResults() throws Exception {
         request.query("FROM ok*,fail*,*:ok*,*:fail* | KEEP id, fail_me | LIMIT 1000");
         request.includeCCSMetadata(randomBoolean());
         {
-            // allow_partial_results = false
-            request.includeCCSMetadata(randomBoolean());
+            request.allowPartialResults(false);
             IllegalStateException error = expectThrows(IllegalStateException.class, () -> runQuery(request).close());
             assertThat(error.getMessage(), containsString("Accessing failing field"));
         }
-        // allow_partial_results = true
         request.allowPartialResults(true);
         try (var resp = runQuery(request)) {
             assertTrue(resp.isPartial());

Original file line number	Diff line number	Diff line change
`@@ -71,12 +71,10 @@ public void testPartialResults() throws Exception {`
`71`	`71`	`request.query("FROM ok,fail,:ok,:fail \| KEEP id, fail_me \| LIMIT 1000");`
`72`	`72`	`request.includeCCSMetadata(randomBoolean());`
`73`	`73`	`{`
`74`		`- // allow_partial_results = false`
`75`		`- request.includeCCSMetadata(randomBoolean());`
	`74`	`+ request.allowPartialResults(false);`
`76`	`75`	`IllegalStateException error = expectThrows(IllegalStateException.class, () -> runQuery(request).close());`
`77`	`76`	`assertThat(error.getMessage(), containsString("Accessing failing field"));`
`78`	`77`	`}`
`79`		`- // allow_partial_results = true`
`80`	`78`	`request.allowPartialResults(true);`
`81`	`79`	`try (var resp = runQuery(request)) {`
`82`	`80`	`assertTrue(resp.isPartial());`