This is an automated email from the ASF dual-hosted git repository.
wangbo 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 0371dec8683 [Fix]Fix query token not release in NereidsCoordinator
(#46004)
0371dec8683 is described below
commit 0371dec86830eba25cbe3432de2a0579f75bb71c
Author: wangbo <wan...@selectdb.com>
AuthorDate: Fri Dec 27 17:07:58 2024 +0800
[Fix]Fix query token not release in NereidsCoordinator (#46004)
---
fe/fe-core/src/main/java/org/apache/doris/qe/NereidsCoordinator.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/qe/NereidsCoordinator.java
b/fe/fe-core/src/main/java/org/apache/doris/qe/NereidsCoordinator.java
index a6f24806ed7..a363aedc0d4 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/NereidsCoordinator.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/NereidsCoordinator.java
@@ -477,8 +477,8 @@ public class NereidsCoordinator extends Coordinator {
}
QueueToken queueToken = queryQueue.getToken();
int queryTimeout =
coordinatorContext.queryOptions.getExecutionTimeout() * 1000;
-
queueToken.get(DebugUtil.printId(coordinatorContext.queryId), queryTimeout);
coordinatorContext.setQueueInfo(queryQueue, queueToken);
+
queueToken.get(DebugUtil.printId(coordinatorContext.queryId), queryTimeout);
}
} else {
context.setWorkloadGroupName("");
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
