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

[enhancement](feservice) catch throwable and print log for frontend service (#17708)

Browse Source 
---------

Co-authored-by: yiguolei <yiguolei@gmail.com>
This commit is contained in:
yiguolei
2023-03-13 11:27:00 +08:00
committed by GitHub
parent 2b31fc1472
commit be5147c32e
1 changed files with 14 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -43,6 +43,7 @@ public class FeServer {
public void start() throws IOException {
FrontendServiceImpl service = new FrontendServiceImpl(ExecuteEnv.getInstance());
Logger feServiceLogger = LogManager.getLogger(FrontendServiceImpl.class);
FrontendService.Iface instance = (FrontendService.Iface) Proxy.newProxyInstance(
FrontendServiceImpl.class.getClassLoader(),
FrontendServiceImpl.class.getInterfaces(),
@ -50,9 +51,19 @@ public class FeServer {
long begin = System.currentTimeMillis();
String name = method.getName();
MetricRepo.THRIFT_COUNTER_RPC_ALL.getOrAdd(name).increase(1L);
Object r = method.invoke(service, args);
long end = System.currentTimeMillis();
MetricRepo.THRIFT_COUNTER_RPC_LATENCY.getOrAdd(name).increase(end - begin);
feServiceLogger.debug("receive request for {}", name);
Object r = null;
try {
r = method.invoke(service, args);
} catch (Throwable t) {
feServiceLogger.warn("errors while process request for {}", name, t);
// If exception occurs, do not deal it, just keep as the previous
throw t;
} finally {
feServiceLogger.debug("finish process request for {}", name);
long end = System.currentTimeMillis();
MetricRepo.THRIFT_COUNTER_RPC_LATENCY.getOrAdd(name).increase(end - begin);
}
return r;
});
// setup frontend server