This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 8e161ad0f21 [debug](timeout) add some log to debug timeout== 0 (#28011)
8e161ad0f21 is described below
commit 8e161ad0f21f697fcc6abe8ee5672a937a92f50c
Author: yiguolei <676222...@qq.com>
AuthorDate: Tue Dec 5 18:35:36 2023 +0800
[debug](timeout) add some log to debug timeout== 0 (#28011)
---------
Co-authored-by: yiguolei <yiguo...@gmail.com>
---
.../src/main/java/org/apache/doris/planner/StreamLoadPlanner.java | 6 ++++++
fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java | 6 ++++++
2 files changed, 12 insertions(+)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/planner/StreamLoadPlanner.java
b/fe/fe-core/src/main/java/org/apache/doris/planner/StreamLoadPlanner.java
index 64e872125d4..54791e8fbee 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/planner/StreamLoadPlanner.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/planner/StreamLoadPlanner.java
@@ -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());
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
index 1ca37d7e70d..489cafa680d 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
@@ -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) {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
