diff --git a/x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/operator/Driver.java b/x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/operator/Driver.java index 00c1f14399525..0ad3c64fcaf09 100644 --- a/x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/operator/Driver.java +++ b/x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/operator/Driver.java @@ -267,7 +267,7 @@ private IsBlockedResult runSingleLoopIteration() { if (op.isFinished() == false && nextOp.needsInput()) { driverContext.checkForEarlyTermination(); - assert nextOp.isFinished() == false || nextOp instanceof ExchangeSinkOperator + assert nextOp.isFinished() == false || nextOp instanceof ExchangeSinkOperator || nextOp instanceof LimitOperator : "next operator should not be finished yet: " + nextOp; Page page = op.getOutput(); if (page == null) {