yiguolei commented on code in PR #33046:
URL: https://github.com/apache/doris/pull/33046#discussion_r1544975255
##########
fe/fe-core/src/main/java/org/apache/doris/qe/ConnectContext.java:
##########
@@ -891,6 +892,24 @@ public void kill(boolean killConnection) {
cancelQuery();
}
+ // kill operation with no protect by timeout.
+ private void killByTimeout(boolean killConnection) {
+ LOG.warn("kill query from {}, kill mysql connection: {} reason time
out", getRemoteHostPortString(),
+ killConnection);
+
+ if (killConnection) {
+ isKilled = true;
+ // Close channel to break connection with client
+ closeChannel();
+ }
+ // Now, cancel running query.
+ // cancelQuery by time out
+ StmtExecutor executorRef = executor;
Review Comment:
why need this variable executorRef? Not use executor directly?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
