agavra commented on code in PR #9887:
URL: https://github.com/apache/pinot/pull/9887#discussion_r1037546935
##########
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/executor/OpChainSchedulerService.java:
##########
@@ -95,9 +95,9 @@ public void runJob() {
if (!result.isEndOfStreamBlock()) {
// not complete, needs to re-register for scheduling
- register(operatorChain);
+ register(operatorChain, false);
Review Comment:
that should never happen with the changes to the operator chain, the
operators process everything that they can process until all inputs available.
in the case of those not hooked with any mailbox they will process everything
and the operator will finish.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
