(doris) branch branch-3.0 updated: [Fix](jdbc-scanner) Fix jdbc scanner memory leak because it didn't close `outputTable`. (#41041)

[dataroaring]

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

dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/branch-3.0 by this push:
     new 365ada137f5 [Fix](jdbc-scanner) Fix jdbc scanner memory leak because 
it didn't close `outputTable`. (#41041)
365ada137f5 is described below

commit 365ada137f5cb4fa5d4531aabead42f7543d6adb
Author: Qi Chen <kaka11.c...@gmail.com>
AuthorDate: Sat Sep 21 20:38:26 2024 +0800

    [Fix](jdbc-scanner) Fix jdbc scanner memory leak because it didn't close 
`outputTable`. (#41041)
    
    ## Proposed changes
    
    [Fix] (jdbc-scanner) Fix jdbc scanner memory leak because it didn't
    close `outputTable`.
---
 .../src/main/java/org/apache/doris/jdbc/BaseJdbcExecutor.java        | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/fe/be-java-extensions/jdbc-scanner/src/main/java/org/apache/doris/jdbc/BaseJdbcExecutor.java
 
b/fe/be-java-extensions/jdbc-scanner/src/main/java/org/apache/doris/jdbc/BaseJdbcExecutor.java
index 3e681fa1519..6e389926571 100644
--- 
a/fe/be-java-extensions/jdbc-scanner/src/main/java/org/apache/doris/jdbc/BaseJdbcExecutor.java
+++ 
b/fe/be-java-extensions/jdbc-scanner/src/main/java/org/apache/doris/jdbc/BaseJdbcExecutor.java
@@ -100,6 +100,9 @@ public abstract class BaseJdbcExecutor implements 
JdbcExecutor {
     }
 
     public void close() throws Exception {
+        if (outputTable != null) {
+            outputTable.close();
+        }
         try {
             if (stmt != null && !stmt.isClosed()) {
                 try {
@@ -112,8 +115,8 @@ public abstract class BaseJdbcExecutor implements 
JdbcExecutor {
             if (conn != null && resultSet != null) {
                 abortReadConnection(conn, resultSet);
             }
-            closeResources(resultSet, stmt, conn);
         } finally {
+            closeResources(resultSet, stmt, conn);
             if (config.getConnectionPoolMinSize() == 0 && hikariDataSource != 
null) {
                 hikariDataSource.close();
                 
JdbcDataSource.getDataSource().getSourcesMap().remove(config.createCacheKey());


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org