database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](fe) fix MetricRepo.THRIFT_COUNTER_RPC_ALL NullPointException (#17552)

Browse Source
This commit is contained in:
Lei Zhang
2023-03-19 11:39:19 +08:00
committed by GitHub
parent b111f9a518
commit 14dcdd188e
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
fe/fe-core/src/main/java/org/apache/doris/service/FeServer.java
View File

@ -50,7 +50,9 @@ public class FeServer {
(proxy, method, args) -> {
long begin = System.currentTimeMillis();
String name = method.getName();
MetricRepo.THRIFT_COUNTER_RPC_ALL.getOrAdd(name).increase(1L);
if (MetricRepo.isInit) {
MetricRepo.THRIFT_COUNTER_RPC_ALL.getOrAdd(name).increase(1L);
}
feServiceLogger.debug("receive request for {}", name);
Object r = null;
try {
@ -61,8 +63,11 @@ public class FeServer {
throw t;
} finally {
feServiceLogger.debug("finish process request for {}", name);
long end = System.currentTimeMillis();
MetricRepo.THRIFT_COUNTER_RPC_LATENCY.getOrAdd(name).increase(end - begin);
if (MetricRepo.isInit) {
long end = System.currentTimeMillis();
MetricRepo.THRIFT_COUNTER_RPC_LATENCY.getOrAdd(name)
.increase(end - begin);
}
}
return r;
});