From 46ad455fff1d8425acb5befd915e65e96ef83ba4 Mon Sep 17 00:00:00 2001
From: Dongyeon <loustler@naverz-corp.com>
Date: Fri, 23 Aug 2024 07:05:16 +0900
Subject: [PATCH] Add a close implementation

---
 .../seatunnel/file/catalog/AbstractFileCatalog.java   | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)

diff --git a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/catalog/AbstractFileCatalog.java b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/catalog/AbstractFileCatalog.java
index f7a1b46a8b4..9bac9062aa9 100644
--- a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/catalog/AbstractFileCatalog.java
+++ b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/catalog/AbstractFileCatalog.java
@@ -32,6 +32,7 @@
 
 import lombok.SneakyThrows;
 
+import java.io.IOException;
 import java.util.List;
 
 public abstract class AbstractFileCatalog implements Catalog {
@@ -51,7 +52,15 @@ protected AbstractFileCatalog(
     public void open() throws CatalogException {}
 
     @Override
-    public void close() throws CatalogException {}
+    public void close() throws CatalogException {
+        if (hadoopFileSystemProxy != null) {
+            try {
+                hadoopFileSystemProxy.close();
+            } catch (IOException e) {
+                throw new CatalogException(e);
+            }
+        }
+    }
 
     @Override
     public String name() {