You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by yi...@apache.org on 2024/05/14 23:51:14 UTC
(hudi) 09/22: [HUDI-7600] Shutdown ExecutorService when HiveMetastoreBasedLockProvider is closed (#10993)
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 46374ff47d44a4c6f4f0774ced5ebb46894ffedc
Author: Zouxxyy <zo...@alibaba-inc.com>
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()));
}