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

[chore](log) Log to trace before wait rpc timeout #28024

Browse Source
This commit is contained in:
zhiqiang
2023-12-09 10:04:43 +08:00
committed by GitHub
parent 9d9b6462bf
commit 42aa174405
1 changed files with 23 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
View File

@ -987,11 +987,21 @@ public class Coordinator implements CoordInterface {
long leftTimeMs,
String operation) throws RpcException, UserException {
if (leftTimeMs <= 0) {
long elapsed = (System.currentTimeMillis() - timeoutDeadline) / 1000 + queryOptions.getExecutionTimeout();
long currentTimeMillis = System.currentTimeMillis();
long elapsed = (currentTimeMillis - timeoutDeadline) / 1000 + queryOptions.getExecutionTimeout();
String msg = String.format(
"timeout before waiting %s rpc, query timeout:%d, already elapsed:%d, left for this:%d",
operation, queryOptions.getExecutionTimeout(), elapsed, leftTimeMs);
operation, queryOptions.getExecutionTimeout(), elapsed, leftTimeMs);
LOG.warn("Query {} {}", DebugUtil.printId(queryId), msg);
if (!queryOptions.isSetExecutionTimeout() || !queryOptions.isSetQueryTimeout()) {
LOG.warn("Query {} does not set timeout info, execution timeout: is_set:{}, value:{}"
+ ", query timeout: is_set:{}, value: {}, "
+ "coordinator timeout deadline {}, cur time millis: {}",
DebugUtil.printId(queryId),
queryOptions.isSetExecutionTimeout(), queryOptions.getExecutionTimeout(),
queryOptions.isSetQueryTimeout(), queryOptions.getQueryTimeout(),
timeoutDeadline, currentTimeMillis);
}
throw new UserException(msg);
}
@ -1054,11 +1064,21 @@ public class Coordinator implements CoordInterface {
Future<PExecPlanFragmentResult>>> futures, long leftTimeMs,
String operation) throws RpcException, UserException {
if (leftTimeMs <= 0) {
long elapsed = (System.currentTimeMillis() - timeoutDeadline) / 1000 + queryOptions.getExecutionTimeout();
long currentTimeMillis = System.currentTimeMillis();
long elapsed = (currentTimeMillis - timeoutDeadline) / 1000 + queryOptions.getExecutionTimeout();
String msg = String.format(
"timeout before waiting %s rpc, query timeout:%d, already elapsed:%d, left for this:%d",
operation, queryOptions.getExecutionTimeout(), elapsed, leftTimeMs);
LOG.warn("Query {} {}", DebugUtil.printId(queryId), msg);
if (!queryOptions.isSetExecutionTimeout() || !queryOptions.isSetQueryTimeout()) {
LOG.warn("Query {} does not set timeout info, execution timeout: is_set:{}, value:{}"
+ ", query timeout: is_set:{}, value: {}, "
+ "coordinator timeout deadline {}, cur time millis: {}",
DebugUtil.printId(queryId),
queryOptions.isSetExecutionTimeout(), queryOptions.getExecutionTimeout(),
queryOptions.isSetQueryTimeout(), queryOptions.getQueryTimeout(),
timeoutDeadline, currentTimeMillis);
}
throw new UserException(msg);
}