(hudi) branch master updated: [HUDI-7600] Shutdown ExecutorService when HiveMetastoreBasedLockProvider is closed (#10993)

[danny0405]

This is an automated email from the ASF dual-hosted git repository.

danny0405 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new c2b5cc91d8e [HUDI-7600] Shutdown ExecutorService when 
HiveMetastoreBasedLockProvider is closed (#10993)
c2b5cc91d8e is described below

commit c2b5cc91d8e56b70498fef731f26c5c67b9d01e8
Author: Zouxxyy <zouxinyu....@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()));
     }