walterddr opened a new pull request, #11970:
URL: https://github.com/apache/pinot/pull/11970
currently agg, window, transform, fitler operator can potentially pull more
than once against input for EOS.
This PR changes the behavior.
- single-input stop-the-world operator (agg, window, sort) only pull once
and check for produced block first
- streaming operator (filter, transform) keeps the behavior
- dual-input, right-sided stop-the-world & left-sided stream operator (join,
set) will only pull EOS on each input at most once
- when right side error out first, left side will not be pulled
this guarantees that no more than one EOS block will be pulled
--
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]
