Skip to content

Commit 53f7d60

Browse files
committed
upd
1 parent 11bd0f0 commit 53f7d60

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

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

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -136,6 +136,12 @@ private void trySendingRequestsForPendingShards(TargetShards targetShards, Compu
136136
reportedFailure = true;
137137
reportFailures(computeListener);
138138
} else {
139+
if (pendingShardIds.isEmpty() && shardFailures.isEmpty() == false) {
140+
reportedFailure = true;
141+
reportFailures(computeListener);
142+
return;
143+
}
144+
139145
for (NodeRequest request : selectNodeRequests(targetShards)) {
140146
sendOneNodeRequest(targetShards, computeListener, request);
141147
}

0 commit comments

Comments
 (0)