HIVE-27447: Iceberg: Queries failing due to FileSystem close errors d…

…ue to column statistics. (apache#4429). (Ayush Saxena, reviewed by Denys Kuzmenko,)
yeahyung · Jul 20, 2023 · 3735c3f · 3735c3f
1 parent a7edbdf
commit 3735c3f
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/...g/iceberg-handler/src/main/java/org/apache/iceberg/mr/hive/HiveIcebergStorageHandler.java b/...g/iceberg-handler/src/main/java/org/apache/iceberg/mr/hive/HiveIcebergStorageHandler.java
@@ -439,7 +439,8 @@ public boolean canProvideColStatistics(org.apache.hadoop.hive.ql.metadata.Table
     Table table = IcebergTableUtil.getTable(conf, hmsTable.getTTable());
     if (canSetColStatistics(hmsTable)) {
       Path statsPath = getStatsPath(table);
-      try (FileSystem fs = statsPath.getFileSystem(conf)) {
+      try {
+        FileSystem fs = statsPath.getFileSystem(conf);
         if (fs.exists(statsPath)) {
           return true;
         }
@@ -496,12 +497,13 @@ private Path getStatsPath(Table table) {
   }
 
   private void invalidateStats(Path statsPath) {
-    try (FileSystem fs = statsPath.getFileSystem(conf)) {
+    try {
+      FileSystem fs = statsPath.getFileSystem(conf);
       if (fs.exists(statsPath)) {
         fs.delete(statsPath, true);
       }
     } catch (IOException e) {
-      LOG.error("Failed to invalidate stale column stats: {}", e);
+      LOG.error("Failed to invalidate stale column stats: {}", e.getMessage());
     }
   }