This is an automated email from the ASF dual-hosted git repository.
rongr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
from fb48288ef6 Allow segment upload via Metadata in MergeRollup Minion task (#9825)
add e6a9881d7d [multistage] improved task scheduling (#9887)
No new revisions were added by this update.
Summary of changes:
.../MultiStageBrokerRequestHandler.java | 5 +-
.../pinot/query/mailbox/GrpcMailboxService.java | 6 +-
.../pinot/query/mailbox/GrpcReceivingMailbox.java | 6 ++
.../query/mailbox/InMemoryMailboxService.java | 12 ++-
.../query/mailbox/InMemoryReceivingMailbox.java | 8 +-
.../query/mailbox/InMemorySendingMailbox.java | 7 +-
.../query/mailbox/MultiplexingMailboxService.java | 7 +-
.../query/mailbox/channel/ChannelManager.java | 8 +-
.../query/mailbox/channel/GrpcMailboxServer.java | 9 +-
.../channel/MailboxContentStreamObserver.java | 49 ++++-----
.../apache/pinot/query/runtime/QueryRunner.java | 28 +++--
.../query/runtime/executor/OpChainScheduler.java | 3 +-
.../runtime/executor/OpChainSchedulerService.java | 10 +-
.../runtime/executor/RoundRobinScheduler.java | 85 +++++++++++++--
.../query/runtime/operator/AggregateOperator.java | 41 ++++----
.../query/runtime/operator/HashJoinOperator.java | 35 ++++---
.../runtime/operator/MailboxReceiveOperator.java | 21 ++--
.../runtime/operator/MailboxSendOperator.java | 16 ++-
.../pinot/query/runtime/operator/OpChain.java | 12 ++-
.../pinot/query/runtime/operator/SortOperator.java | 38 +++----
.../query/runtime/plan/PhysicalPlanVisitor.java | 15 ++-
.../query/runtime/plan/PlanRequestContext.java | 13 +++
.../apache/pinot/query/service/QueryServer.java | 25 ++---
.../apache/pinot/query/QueryServerEnclosure.java | 11 +-
.../query/mailbox/GrpcMailboxServiceTest.java | 93 +++++++++++------
.../query/mailbox/GrpcMailboxServiceTestBase.java | 53 ----------
.../query/mailbox/InMemoryMailboxServiceTest.java | 4 +-
.../pinot/query/runtime/QueryRunnerTest.java | 3 +-
.../executor/OpChainSchedulerServiceTest.java | 15 +--
.../runtime/executor/RoundRobinSchedulerTest.java | 116 +++++++++++++++++++--
.../runtime/operator/AggregateOperatorTest.java | 31 +++---
.../runtime/operator/HashJoinOperatorTest.java | 6 +-
.../operator/MailboxReceiveOperatorTest.java | 32 ++++++
.../runtime/operator/MailboxSendOperatorTest.java | 10 +-
.../query/runtime/operator/SortOperatorTest.java | 16 +--
.../runtime/queries/ResourceBasedQueriesTest.java | 3 +-
.../pinot/query/service/QueryServerTest.java | 5 +-
37 files changed, 551 insertions(+), 306 deletions(-)
delete mode 100644 pinot-query-runtime/src/test/java/org/apache/pinot/query/mailbox/GrpcMailboxServiceTestBase.java
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org