This is an automated email from the ASF dual-hosted git repository.
Jackie-Jiang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new 91be61f0f4f Make the server query meter table level (#18882)
91be61f0f4f is described below
commit 91be61f0f4f6c90dd11722f005af43b2a145cb76
Author: Jhow <[email protected]>
AuthorDate: Wed Jul 1 12:34:00 2026 -0700
Make the server query meter table level (#18882)
---
.../src/main/java/org/apache/pinot/common/metrics/ServerMeter.java | 1 +
.../java/org/apache/pinot/core/transport/InstanceRequestHandler.java | 1 +
2 files changed, 2 insertions(+)
diff --git
a/pinot-common/src/main/java/org/apache/pinot/common/metrics/ServerMeter.java
b/pinot-common/src/main/java/org/apache/pinot/common/metrics/ServerMeter.java
index b0d2a7fe975..c5dc9855006 100644
---
a/pinot-common/src/main/java/org/apache/pinot/common/metrics/ServerMeter.java
+++
b/pinot-common/src/main/java/org/apache/pinot/common/metrics/ServerMeter.java
@@ -27,6 +27,7 @@ import org.apache.pinot.spi.metrics.PinotMeter;
*/
public enum ServerMeter implements AbstractMetrics.Meter {
QUERIES("queries", true),
+ QUERIES_ON_TABLE("queries", false),
UNCAUGHT_EXCEPTIONS("exceptions", true),
REQUEST_DESERIALIZATION_EXCEPTIONS("exceptions", true),
RESPONSE_SERIALIZATION_EXCEPTIONS("exceptions", true),
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/transport/InstanceRequestHandler.java
b/pinot-core/src/main/java/org/apache/pinot/core/transport/InstanceRequestHandler.java
index 98fa80349b7..975f0c015bc 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/transport/InstanceRequestHandler.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/transport/InstanceRequestHandler.java
@@ -130,6 +130,7 @@ public class InstanceRequestHandler extends
SimpleChannelInboundHandler<ByteBuf>
InstanceRequest instanceRequest = new InstanceRequest();
THREAD_LOCAL_T_DESERIALIZER.get().deserialize(instanceRequest,
requestBytes);
queryRequest = new ServerQueryRequest(instanceRequest, _serverMetrics,
queryArrivalTimeMs);
+ _serverMetrics.addMeteredTableValue(queryRequest.getTableNameWithType(),
ServerMeter.QUERIES_ON_TABLE, 1);
queryRequest.getTimerContext().startNewPhaseTimer(ServerQueryPhase.REQUEST_DESERIALIZATION,
queryArrivalTimeMs)
.stopAndRecord();
} catch (Exception e) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
