Skip to content

Commit a1ed9a4

Browse files
committed
handle rows
1 parent 7930c2a commit a1ed9a4

File tree

1 file changed

+3
-0
lines changed
  • x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/session

1 file changed

+3
-0
lines changed

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/session/EsqlCCSUtils.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -402,6 +402,9 @@ public static Set<String> getRemotesOf(Set<String> concreteIndices) {
402402
* This is needed in order to require lookup index is present on every remote in order to correctly execute a query with join.
403403
*/
404404
public static String qualifyWithRunningRemotes(String index, Set<String> remotes, EsqlExecutionInfo executionInfo) {
405+
if (remotes.isEmpty()) {
406+
return index;
407+
}
405408
return remotes.stream().filter(remote -> {
406409
var cluster = executionInfo.getCluster(remote);
407410
return cluster == null || cluster.getStatus() == Cluster.Status.RUNNING;

0 commit comments

Comments
 (0)