This is an automated email from the ASF dual-hosted git repository.

morningman pushed a commit to branch branch-2.1-lakehouse
in repository https://gitbox.apache.org/repos/asf/doris.git

commit a98f28916fcdcc4d38fb5c769a99309da637879f
Author: wuwenchi <[email protected]>
AuthorDate: Wed Sep 18 18:59:27 2024 +0800

    [improvement](mem)Dereference for executor (#40800)
    
    ## Proposed changes
    
    When a cmd is executed, we can cancel the reference to the `executor` to
    release the related resources. Otherwise, these resources can only be
    released when the next cmd is executed.
---
 .../src/main/java/org/apache/doris/qe/AutoCloseConnectContext.java      | 1 +
 fe/fe-core/src/main/java/org/apache/doris/qe/MysqlConnectProcessor.java | 2 ++
 2 files changed, 3 insertions(+)

diff --git 
a/fe/fe-core/src/main/java/org/apache/doris/qe/AutoCloseConnectContext.java 
b/fe/fe-core/src/main/java/org/apache/doris/qe/AutoCloseConnectContext.java
index ffebe97e706..0c400950c58 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/AutoCloseConnectContext.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/AutoCloseConnectContext.java
@@ -36,6 +36,7 @@ public class AutoCloseConnectContext implements AutoCloseable 
{
 
     @Override
     public void close() {
+        connectContext.clear();
         ConnectContext.remove();
         if (previousContext != null) {
             previousContext.setThreadLocalInfo();
diff --git 
a/fe/fe-core/src/main/java/org/apache/doris/qe/MysqlConnectProcessor.java 
b/fe/fe-core/src/main/java/org/apache/doris/qe/MysqlConnectProcessor.java
index f86833451f8..b283e9ec876 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/MysqlConnectProcessor.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/MysqlConnectProcessor.java
@@ -485,6 +485,8 @@ public class MysqlConnectProcessor extends ConnectProcessor 
{
         finalizeCommand();
 
         ctx.setCommand(MysqlCommand.COM_SLEEP);
+        ctx.clear();
+        executor = null;
     }
 
     public void loop() {


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to