Add a close implementation

loustler · Aug 22, 2024 · 46ad455 · 46ad455
1 parent 1bacc3f
commit 46ad455
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/...main/java/org/apache/seatunnel/connectors/seatunnel/file/catalog/AbstractFileCatalog.java b/...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() {