1

apache · Dec 17, 2024 · 975427a · 975427a
1 parent 826200e
commit 975427a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/pool/CachedClientPool.java b/...-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/pool/CachedClientPool.java
@@ -207,7 +207,7 @@ static Key extractKey(String clientClassName, String cacheKeys, Configuration co
     @Override
     public void close() throws IOException {
         if (clientPoolCache != null) {
-            clientPoolCache.asMap().forEach((key, client) -> client.close());
+            clientPoolCache.asMap().values().forEach(HiveClientPool::close);
             clientPoolCache.cleanUp();
         }
     }