From d1c9b28a504cf261ac842512c639a27f3db20d69 Mon Sep 17 00:00:00 2001
From: morningman <yunyou@selectdb.com>
Date: Wed, 12 Feb 2025 16:19:09 +0800
Subject: [PATCH] [fix](trino-connector) close scanner after finished

---
 .../apache/doris/trinoconnector/TrinoConnectorJniScanner.java  | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/fe/be-java-extensions/trino-connector-scanner/src/main/java/org/apache/doris/trinoconnector/TrinoConnectorJniScanner.java b/fe/be-java-extensions/trino-connector-scanner/src/main/java/org/apache/doris/trinoconnector/TrinoConnectorJniScanner.java
index 6b15abfa413043..2138a432037e8a 100644
--- a/fe/be-java-extensions/trino-connector-scanner/src/main/java/org/apache/doris/trinoconnector/TrinoConnectorJniScanner.java
+++ b/fe/be-java-extensions/trino-connector-scanner/src/main/java/org/apache/doris/trinoconnector/TrinoConnectorJniScanner.java
@@ -179,6 +179,9 @@ public void open() throws IOException {
 
     @Override
     public void close() throws IOException {
+        if (source != null) {
+            source.close();
+        }
     }
 
     @Override