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

[debug](timeout) add some log to debug timeout== 0 (#28011)

Browse Source 
---------

Co-authored-by: yiguolei <yiguolei@gmail.com>
This commit is contained in:
yiguolei
2023-12-05 18:35:36 +08:00
committed by GitHub
parent 59c0db4080
commit 8e161ad0f2
2 changed files with 12 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
fe/fe-core/src/main/java/org/apache/doris/planner/StreamLoadPlanner.java
View File

@ -308,6 +308,9 @@ public class StreamLoadPlanner {
queryOptions.setQueryType(TQueryType.LOAD);
queryOptions.setQueryTimeout(timeout);
queryOptions.setExecutionTimeout(timeout);
if (timeout < 1) {
LOG.info("try set timeout less than 1", new RuntimeException(""));
}
queryOptions.setMemLimit(taskInfo.getMemLimit());
// for stream load, we use exec_mem_limit to limit the memory usage of load channel.
queryOptions.setLoadMemLimit(taskInfo.getMemLimit());
@ -527,6 +530,9 @@ public class StreamLoadPlanner {
queryOptions.setQueryType(TQueryType.LOAD);
queryOptions.setQueryTimeout(timeout);
queryOptions.setExecutionTimeout(timeout);
if (timeout < 1) {
LOG.info("try set timeout less than 1", new RuntimeException(""));
}
queryOptions.setMemLimit(taskInfo.getMemLimit());
// for stream load, we use exec_mem_limit to limit the memory usage of load channel.
queryOptions.setLoadMemLimit(taskInfo.getMemLimit());

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

@ -372,6 +372,9 @@ public class Coordinator implements CoordInterface {
this.queryOptions.setBeExecVersion(Config.be_exec_version);
this.queryOptions.setQueryTimeout(context.getExecTimeout());
this.queryOptions.setExecutionTimeout(context.getExecTimeout());
if (this.queryOptions.getExecutionTimeout() < 1) {
LOG.info("try set timeout less than 1", new RuntimeException(""));
}
this.queryOptions.setEnableScanNodeRunSerial(context.getSessionVariable().isEnableScanRunSerial());
this.queryOptions.setFeProcessUuid(ExecuteEnv.getInstance().getProcessUUID());
this.queryOptions.setWaitFullBlockScheduleTimes(context.getSessionVariable().getWaitFullBlockScheduleTimes());
@ -432,6 +435,9 @@ public class Coordinator implements CoordInterface {
public void setTimeout(int timeout) {
this.queryOptions.setQueryTimeout(timeout);
this.queryOptions.setExecutionTimeout(timeout);
if (this.queryOptions.getExecutionTimeout() < 1) {
LOG.info("try set timeout less than 1", new RuntimeException(""));
}
}
public void setLoadZeroTolerance(boolean loadZeroTolerance) {