Skip to content

Commit bf4aea8

Browse files
committed
Improve Lookup operator test for status
1 parent 1b5ae7d commit bf4aea8

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

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

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,6 @@
8282
import java.util.stream.LongStream;
8383

8484
import static org.hamcrest.Matchers.equalTo;
85-
import static org.hamcrest.Matchers.greaterThanOrEqualTo;
8685
import static org.hamcrest.Matchers.matchesPattern;
8786
import static org.mockito.Mockito.mock;
8887

@@ -307,12 +306,11 @@ public void release() {
307306

308307
@Override
309308
protected MapMatcher extendStatusMatcher(MapMatcher mapMatcher, List<Page> input, List<Page> output) {
310-
var totalPages = input.size();
311309
var totalInputRows = input.stream().mapToInt(Page::getPositionCount).sum();
312310
var totalOutputRows = output.stream().mapToInt(Page::getPositionCount).sum();
313311

314312
return mapMatcher.entry("total_rows", totalInputRows)
315-
.entry("pages_emitted", greaterThanOrEqualTo(totalPages))
316-
.entry("rows_emitted", greaterThanOrEqualTo(totalOutputRows));
313+
.entry("pages_emitted", output.size())
314+
.entry("rows_emitted", totalOutputRows);
317315
}
318316
}

0 commit comments

Comments
 (0)