Core: Close FileIO instance in JdbcCatalog (#12540)

rcjverhoef · web-flow · commit bf2f552722b8 · 2025-03-17T12:29:08.000+01:00
diff --git a/core/src/main/java/org/apache/iceberg/jdbc/JdbcCatalog.java b/core/src/main/java/org/apache/iceberg/jdbc/JdbcCatalog.java
@@ -151,6 +151,7 @@ public void initialize(String name, Map<String, String> properties) {
     this.closeableGroup = new CloseableGroup();
     closeableGroup.addCloseable(metricsReporter());
     closeableGroup.addCloseable(connections);
+    closeableGroup.addCloseable(io);
     closeableGroup.setSuppressCloseFailure(true);
   }
 

Original file line number	Diff line number	Diff line change
`@@ -151,6 +151,7 @@ public void initialize(String name, Map<String, String> properties) {`
`151`	`151`	`this.closeableGroup = new CloseableGroup();`
`152`	`152`	`closeableGroup.addCloseable(metricsReporter());`
`153`	`153`	`closeableGroup.addCloseable(connections);`
	`154`	`+ closeableGroup.addCloseable(io);`
`154`	`155`	`closeableGroup.setSuppressCloseFailure(true);`
`155`	`156`	`}`
`156`	`157`