You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by jl...@apache.org on 2025/01/16 06:51:41 UTC
(pinot) branch hotfix-npe created (now 43254690fc)
This is an automated email from the ASF dual-hosted git repository.
jlli pushed a change to branch hotfix-npe
in repository https://gitbox.apache.org/repos/asf/pinot.git
at 43254690fc Fix NPE caused by MultiStageQueryThrottler (#14805)
This branch includes the following new commits:
new 43254690fc Fix NPE caused by MultiStageQueryThrottler (#14805)
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org
(pinot) 01/01: Fix NPE caused by MultiStageQueryThrottler (#14805)
Posted by jl...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
jlli pushed a commit to branch hotfix-npe
in repository https://gitbox.apache.org/repos/asf/pinot.git
commit 43254690fc1ed8f699196e23ca579f87b010ac15
Author: Jialiang Li <jl...@linkedin.com>
AuthorDate: Mon Jan 13 18:00:29 2025 -0800
Fix NPE caused by MultiStageQueryThrottler (#14805)
---
.../org/apache/pinot/broker/broker/helix/BaseBrokerStarter.java | 8 ++++++--
1 file changed, 6 insertions(+), 2 deletions(-)
diff --git a/pinot-broker/src/main/java/org/apache/pinot/broker/broker/helix/BaseBrokerStarter.java b/pinot-broker/src/main/java/org/apache/pinot/broker/broker/helix/BaseBrokerStarter.java
index 2aab062730..fa40afb2db 100644
--- a/pinot-broker/src/main/java/org/apache/pinot/broker/broker/helix/BaseBrokerStarter.java
+++ b/pinot-broker/src/main/java/org/apache/pinot/broker/broker/helix/BaseBrokerStarter.java
@@ -406,7 +406,9 @@ public abstract class BaseBrokerStarter implements ServiceStartable {
clusterConfigChangeHandler.init(_spectatorHelixManager);
}
_clusterConfigChangeHandlers.add(_queryQuotaManager);
- _clusterConfigChangeHandlers.add(_multiStageQueryThrottler);
+ if (_multiStageQueryThrottler != null) {
+ _clusterConfigChangeHandlers.add(_multiStageQueryThrottler);
+ }
for (ClusterChangeHandler idealStateChangeHandler : _idealStateChangeHandlers) {
idealStateChangeHandler.init(_spectatorHelixManager);
}
@@ -416,7 +418,9 @@ public abstract class BaseBrokerStarter implements ServiceStartable {
}
_externalViewChangeHandlers.add(_routingManager);
_externalViewChangeHandlers.add(_queryQuotaManager);
- _externalViewChangeHandlers.add(_multiStageQueryThrottler);
+ if (_multiStageQueryThrottler != null) {
+ _externalViewChangeHandlers.add(_multiStageQueryThrottler);
+ }
for (ClusterChangeHandler instanceConfigChangeHandler : _instanceConfigChangeHandlers) {
instanceConfigChangeHandler.init(_spectatorHelixManager);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org