gianm opened a new pull request, #20589:
URL: https://github.com/apache/druid/pull/20589
Three changes:
1) Check the shared count on every row. The cost of an atomic read
should be negligible next to the cost of reading and writing a row.
2) Provide a mechanism for ReadableInputQueue to stop loading and
handing out segments once the limit has been reached.
3) Fix a bug where ChainedProcessorManager did not close its first
delegate ProcessorManager. This in turn could cause segments to leak
from ReadableInputQueue on early exit.
--
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]
