|
@@ -267,7 +267,7 @@ public class Driver implements Releasable, Describable {
|
|
|
|
|
|
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) {
|