From 8e161ad0f21f697fcc6abe8ee5672a937a92f50c Mon Sep 17 00:00:00 2001 From: yiguolei <676222867@qq.com> Date: Tue, 5 Dec 2023 18:35:36 +0800 Subject: [PATCH] [debug](timeout) add some log to debug timeout== 0 (#28011) --------- Co-authored-by: yiguolei --- .../java/org/apache/doris/planner/StreamLoadPlanner.java | 6 ++++++ .../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 64e872125d..54791e8fbe 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 1ca37d7e70..489cafa680 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) {