This is an automated email from the ASF dual-hosted git repository.
jackie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
from 2c023895a2 Fix intermediate stage routing for multi-stage engine
(#11393)
add 76e3899bcf Remove dedicated executor for exchange (#11394)
No new revisions were added by this update.
Summary of changes:
.../pinot/query/mailbox/GrpcSendingMailbox.java | 12 +-
.../query/mailbox/InMemorySendingMailbox.java | 6 +-
.../apache/pinot/query/mailbox/MailboxIdUtils.java | 11 +-
.../apache/pinot/query/mailbox/MailboxService.java | 65 +--------
.../pinot/query/mailbox/ReceivingMailbox.java | 16 +--
.../apache/pinot/query/mailbox/SendingMailbox.java | 3 +-
.../apache/pinot/query/runtime/QueryRunner.java | 2 -
.../operator/BaseMailboxReceiveOperator.java | 10 +-
.../runtime/operator/MailboxSendOperator.java | 45 ++----
.../runtime/operator/exchange/BlockExchange.java | 101 ++-----------
.../operator/exchange/BroadcastExchange.java | 7 +-
.../runtime/operator/exchange/HashExchange.java | 8 +-
.../runtime/operator/exchange/RandomExchange.java | 12 +-
.../operator/exchange/SingletonExchange.java | 7 +-
.../runtime/plan/OpChainExecutionContext.java | 5 -
.../apache/pinot/query/service/QueryConfig.java | 23 +--
.../apache/pinot/query/QueryServerEnclosure.java | 1 -
.../pinot/query/mailbox/MailboxServiceTest.java | 158 ++++++++-------------
.../runtime/operator/MailboxSendOperatorTest.java | 17 ++-
.../pinot/query/runtime/operator/OpChainTest.java | 4 +-
.../operator/exchange/BlockExchangeTest.java | 54 +------
.../operator/exchange/BroadcastExchangeTest.java | 4 +-
.../operator/exchange/HashExchangeTest.java | 4 +-
.../operator/exchange/RandomExchangeTest.java | 4 +-
.../operator/exchange/SingletonExchangeTest.java | 10 +-
.../runtime/queries/ResourceBasedQueriesTest.java | 3 +-
26 files changed, 144 insertions(+), 448 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
