LakshSingla opened a new pull request, #19607: URL: https://github.com/apache/druid/pull/19607
`DirectDruidClient` returns a `SequenceInputStream` consisting of the chunks fetched by the downstream data servers. `close()` on the `SequenceInputStream` consumes the entire iteration, attempts to call close on the elements, before returning to the caller. This means that on attempting to `close()` the input stream returned by the DirectDruidClient, we end up fetching the entire response from the data servers. This fetching is wasteful, as we discard the results, and there's nothing to be done on the remaining chunks. This PR short-circuits the close() on the stream returned by the DirectDruidClient, so that close() exits immediately, and terminates the connection between the broker and the dataservers. -- 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]
