This is an automated email from the ASF dual-hosted git repository.
yashmayya pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
from 246b98c7e1 [flaky-test] Increase Timeouts for TPCHQueryIntegrationTest
and MultiStageEngineIntegrationTest (#14653)
add 6286109641 Add cluster configuration to allow limiting the number of
multi-stage queries running concurrently (#14574)
No new revisions were added by this update.
Summary of changes:
.../broker/broker/helix/BaseBrokerStarter.java | 8 +-
.../MultiStageBrokerRequestHandler.java | 135 +++++----
.../requesthandler/MultiStageQueryThrottler.java | 166 +++++++++++
.../MultiStageQueryThrottlerTest.java | 328 +++++++++++++++++++++
.../common/concurrency/AdjustableSemaphore.java | 40 +--
.../java/org/apache/pinot/common/utils/Timer.java | 57 ++++
.../tests/MultiStageEngineIntegrationTest.java | 37 +++
.../apache/pinot/spi/utils/CommonConstants.java | 5 +
8 files changed, 700 insertions(+), 76 deletions(-)
create mode 100644
pinot-broker/src/main/java/org/apache/pinot/broker/requesthandler/MultiStageQueryThrottler.java
create mode 100644
pinot-broker/src/test/java/org/apache/pinot/broker/requesthandler/MultiStageQueryThrottlerTest.java
copy
pinot-core/src/main/java/org/apache/pinot/core/operator/dociditerators/MatchAllDocIdIterator.java
=>
pinot-common/src/main/java/org/apache/pinot/common/concurrency/AdjustableSemaphore.java
(53%)
create mode 100644
pinot-common/src/main/java/org/apache/pinot/common/utils/Timer.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
