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) <[email protected]> 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: [email protected] For additional commands, e-mail: [email protected]
