Skip to content

Commit 5dbbd22

Browse files
committed
Update test after merge
1 parent a775efb commit 5dbbd22

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

x-pack/plugin/esql/src/test/java/org/elasticsearch/xpack/esql/enrich/LookupFromIndexOperatorTests.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -308,10 +308,10 @@ public void release() {
308308
@Override
309309
protected void checkOperatorStatusFields(Map<String, Object> status, List<Page> input, List<Page> output) {
310310
var totalPages = input.size();
311-
var totalInutValues = input.stream().mapToLong(p -> p.getBlock(0).getTotalValueCount()).sum();
312-
var totalOutputRows = input.stream().mapToLong(p -> p.getPositionCount()).sum();
311+
var totalInputRows = input.stream().mapToLong(p -> p.getPositionCount()).sum();
312+
var totalOutputRows = output.stream().mapToLong(p -> p.getPositionCount()).sum();
313313

314-
assertThat(status, hasEntry(is("total_terms"), matchNumberEqualTo(totalInutValues)));
314+
assertThat(status, hasEntry(is("total_rows"), matchNumberEqualTo(totalInputRows)));
315315
assertThat(status, hasEntry(is("pages_completed"), matchNumberEqualTo(totalPages)));
316316
assertThat(status, hasEntry(is("pages_emitted"), matchNumberGreaterThanOrEqualTo(totalPages)));
317317
assertThat(status, hasEntry(is("rows_emitted"), matchNumberGreaterThanOrEqualTo(totalOutputRows)));

0 commit comments

Comments
 (0)