Skip to content

Commit a0ba48d

Browse files
committed
Don't emit metric in transportTerminated if transportAttrs is null
1 parent c702e3a commit a0ba48d

File tree

1 file changed

+6
-3
lines changed

1 file changed

+6
-3
lines changed

pinot-core/src/main/java/org/apache/pinot/core/transport/grpc/GrpcQueryServer.java

+6-3
Original file line numberDiff line numberDiff line change
@@ -89,9 +89,12 @@ public Attributes transportReady(Attributes transportAttrs) {
8989

9090
@Override
9191
public void transportTerminated(Attributes transportAttrs) {
92-
LOGGER.info("gRPC transportTerminated: REMOTE_ADDR {}",
93-
transportAttrs != null ? transportAttrs.get(Grpc.TRANSPORT_ATTR_REMOTE_ADDR) : "null");
94-
_serverMetrics.addMeteredGlobalValue(ServerMeter.GRPC_TRANSPORT_TERMINATED, 1);
92+
// transportTerminated can be called without transportReady before it, e.g. handshake fails
93+
// So, don't emit metrics if transportAttrs is null
94+
if (transportAttrs != null) {
95+
LOGGER.info("gRPC transportTerminated: REMOTE_ADDR {}", transportAttrs.get(Grpc.TRANSPORT_ATTR_REMOTE_ADDR));
96+
_serverMetrics.addMeteredGlobalValue(ServerMeter.GRPC_TRANSPORT_TERMINATED, 1);
97+
}
9598
}
9699
}
97100

0 commit comments

Comments
 (0)