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 2022/06/30 19:57:17 UTC
[pinot] branch remove-double-couting created (now c64a30ffae)
This is an automated email from the ASF dual-hosted git repository.
jlli pushed a change to branch remove-double-couting
in repository https://gitbox.apache.org/repos/asf/pinot.git
at c64a30ffae Remove double counting on pinot-server
This branch includes the following new commits:
new c64a30ffae Remove double counting on pinot-server
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: Remove double counting on pinot-server
Posted by jl...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
jlli pushed a commit to branch remove-double-couting
in repository https://gitbox.apache.org/repos/asf/pinot.git
commit c64a30ffae94731104e560d00921f02807cfaa58
Author: Jack Li(Analytics Engineering) <jl...@jlli-mn1.linkedin.biz>
AuthorDate: Thu Jun 30 12:57:01 2022 -0700
Remove double counting on pinot-server
---
.../java/org/apache/pinot/core/query/scheduler/PriorityScheduler.java | 2 --
1 file changed, 2 deletions(-)
diff --git a/pinot-core/src/main/java/org/apache/pinot/core/query/scheduler/PriorityScheduler.java b/pinot-core/src/main/java/org/apache/pinot/core/query/scheduler/PriorityScheduler.java
index 95b50befd2..18f97ccdce 100644
--- a/pinot-core/src/main/java/org/apache/pinot/core/query/scheduler/PriorityScheduler.java
+++ b/pinot-core/src/main/java/org/apache/pinot/core/query/scheduler/PriorityScheduler.java
@@ -27,7 +27,6 @@ import java.util.List;
import java.util.concurrent.Semaphore;
import java.util.concurrent.atomic.LongAccumulator;
import org.apache.pinot.common.exception.QueryException;
-import org.apache.pinot.common.metrics.ServerMeter;
import org.apache.pinot.common.metrics.ServerMetrics;
import org.apache.pinot.common.metrics.ServerQueryPhase;
import org.apache.pinot.core.query.executor.QueryExecutor;
@@ -75,7 +74,6 @@ public abstract class PriorityScheduler extends QueryScheduler {
LOGGER.error("Out of capacity for table {}, message: {}", queryRequest.getTableNameWithType(), e.getMessage());
return immediateErrorResponse(queryRequest, QueryException.SERVER_OUT_OF_CAPACITY_ERROR);
}
- _serverMetrics.addMeteredTableValue(queryRequest.getTableNameWithType(), ServerMeter.QUERIES, 1);
return schedQueryContext.getResultFuture();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org