Skip to content

Commit 0f41047

Browse files
committed
Don't think skipped ones should be initialized with total number. (elastic#127944)
I suspect this might be the reason for failures in CrossClusterQueryWithFiltersIT (cherry picked from commit 5447909) # Conflicts: # muted-tests.yml
1 parent eee1d29 commit 0f41047

File tree

1 file changed

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

1 file changed

+3
-3
lines changed

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -349,9 +349,9 @@ public static void markClusterWithFinalStateAndNoShards(
349349
Cluster.Builder builder = new Cluster.Builder(v).setStatus(status)
350350
.setTook(executionInfo.tookSoFar())
351351
.setTotalShards(Objects.requireNonNullElse(v.getTotalShards(), 0))
352-
.setSuccessfulShards(Objects.requireNonNullElse(v.getTotalShards(), 0))
353-
.setSkippedShards(Objects.requireNonNullElse(v.getTotalShards(), 0))
354-
.setFailedShards(Objects.requireNonNullElse(v.getTotalShards(), 0));
352+
.setSuccessfulShards(Objects.requireNonNullElse(v.getSuccessfulShards(), 0))
353+
.setSkippedShards(Objects.requireNonNullElse(v.getSkippedShards(), 0))
354+
.setFailedShards(Objects.requireNonNullElse(v.getFailedShards(), 0));
355355
if (ex != null) {
356356
builder.setFailures(List.of(new ShardSearchFailure(ex)));
357357
}

0 commit comments

Comments
 (0)