From 975427ae9e6958e04f1397aae29e9b3121eb9f3e Mon Sep 17 00:00:00 2001
From: zouxxyy <zouxinyu.zxy@alibaba-inc.com>
Date: Tue, 17 Dec 2024 19:33:29 +0800
Subject: [PATCH] 1

---
 .../main/java/org/apache/paimon/hive/pool/CachedClientPool.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/pool/CachedClientPool.java b/paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/pool/CachedClientPool.java
index 027a213206ef..7e3b45a5e0ae 100644
--- a/paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/pool/CachedClientPool.java
+++ b/paimon-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();
         }
     }