From a8d41d5d21b995d232114d78f047afa97123fe45 Mon Sep 17 00:00:00 2001 From: "ievgen.degtiarenko" Date: Fri, 19 Dec 2025 09:17:31 +0100 Subject: [PATCH 1/2] Test data selector resolution --- .../org/elasticsearch/xpack/esql/plugin/IndexResolutionIT.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/x-pack/plugin/esql/src/internalClusterTest/java/org/elasticsearch/xpack/esql/plugin/IndexResolutionIT.java b/x-pack/plugin/esql/src/internalClusterTest/java/org/elasticsearch/xpack/esql/plugin/IndexResolutionIT.java index 11b35dee31fc2..8905635c7ab30 100644 --- a/x-pack/plugin/esql/src/internalClusterTest/java/org/elasticsearch/xpack/esql/plugin/IndexResolutionIT.java +++ b/x-pack/plugin/esql/src/internalClusterTest/java/org/elasticsearch/xpack/esql/plugin/IndexResolutionIT.java @@ -86,6 +86,9 @@ public void testResolvesDataStream() { try (var response = run(syncEsqlQueryRequest("FROM data-stream-1"))) { assertOk(response); } + try (var response = run(syncEsqlQueryRequest("FROM data-stream-1::data"))) { + assertOk(response); + } } public void testResolvesPattern() { From 8dc48f4ee1a6321b250262010694434b6ebfbfee Mon Sep 17 00:00:00 2001 From: "ievgen.degtiarenko" Date: Fri, 19 Dec 2025 13:52:39 +0100 Subject: [PATCH 2/2] add negative test cases --- .../xpack/esql/plugin/IndexResolutionIT.java | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/x-pack/plugin/esql/src/internalClusterTest/java/org/elasticsearch/xpack/esql/plugin/IndexResolutionIT.java b/x-pack/plugin/esql/src/internalClusterTest/java/org/elasticsearch/xpack/esql/plugin/IndexResolutionIT.java index 8905635c7ab30..058d9e76b8d75 100644 --- a/x-pack/plugin/esql/src/internalClusterTest/java/org/elasticsearch/xpack/esql/plugin/IndexResolutionIT.java +++ b/x-pack/plugin/esql/src/internalClusterTest/java/org/elasticsearch/xpack/esql/plugin/IndexResolutionIT.java @@ -89,6 +89,16 @@ public void testResolvesDataStream() { try (var response = run(syncEsqlQueryRequest("FROM data-stream-1::data"))) { assertOk(response); } + expectThrows( + org.elasticsearch.xpack.esql.parser.ParsingException.class, + containsString("Invalid index name [data-stream-1::fake]"), + () -> run(syncEsqlQueryRequest("FROM data-stream-1::fake")) + ); + expectThrows( + VerificationException.class, + containsString("Unknown index [no-such-data-stream::data]"), + () -> run(syncEsqlQueryRequest("FROM no-such-data-stream::data")) + ); } public void testResolvesPattern() {