This is an automated email from the ASF dual-hosted git repository. yihua pushed a commit to branch branch-0.x in repository https://gitbox.apache.org/repos/asf/hudi.git
commit ea01c0ff19406289151c25de8c178823cabda8ab Author: Zouxxyy <[email protected]> AuthorDate: Thu Apr 11 13:03:14 2024 +0800 [HUDI-7600] Shutdown ExecutorService when HiveMetastoreBasedLockProvider is closed (#10993) --- .../hudi/hive/transaction/lock/HiveMetastoreBasedLockProvider.java | 1 + 1 file changed, 1 insertion(+) diff --git a/hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/transaction/lock/HiveMetastoreBasedLockProvider.java b/hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/transaction/lock/HiveMetastoreBasedLockProvider.java index df848957492..0280621bb53 100644 --- a/hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/transaction/lock/HiveMetastoreBasedLockProvider.java +++ b/hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/transaction/lock/HiveMetastoreBasedLockProvider.java @@ -154,6 +154,7 @@ public class HiveMetastoreBasedLockProvider implements LockProvider<LockResponse lock = null; } Hive.closeCurrent(); + executor.shutdown(); } catch (Exception e) { LOG.error(generateLogStatement(org.apache.hudi.common.lock.LockState.FAILED_TO_RELEASE, generateLogSuffixString())); }
