walterddr opened a new pull request, #10797: URL: https://github.com/apache/pinot/pull/10797
singleton exchange was broken b/c of the worker assignment strategy. This is a fix for instantiating singleton exchange, more to follow up properly this change === - only send data via the local exchange and doesn't send data over the network I/O - will still make broadcast of EOS block to all mailbox (regardless of whether they are local) for signaling an end of a stage) follow up === - make sure it work with multiple worker on the same host (partition strategy and worker assignment) - make mailbox assignment visitor to create proper list of send/receive based on exchange type instead of creating a fully-connected network and only send EOS over the wire for network I/O -- 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]
