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

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


The following commit(s) were added to refs/heads/master by this push:
     new f7b9621bc Core: Fix token refresh thread shutdown (#4958)
f7b9621bc is described below

commit f7b9621bc8ef80307814c7fd2ce1327940a775a9
Author: Bryan Keller <[email protected]>
AuthorDate: Sun Jun 5 10:52:51 2022 -0700

    Core: Fix token refresh thread shutdown (#4958)
---
 core/src/main/java/org/apache/iceberg/rest/RESTSessionCatalog.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/core/src/main/java/org/apache/iceberg/rest/RESTSessionCatalog.java 
b/core/src/main/java/org/apache/iceberg/rest/RESTSessionCatalog.java
index 60e94b572..9f5a4b560 100644
--- a/core/src/main/java/org/apache/iceberg/rest/RESTSessionCatalog.java
+++ b/core/src/main/java/org/apache/iceberg/rest/RESTSessionCatalog.java
@@ -369,6 +369,7 @@ public class RESTSessionCatalog extends BaseSessionCatalog 
implements Configurab
       ScheduledExecutorService service = refreshExecutor;
       this.refreshExecutor = null;
 
+      service.shutdown();
       try {
         if (service.awaitTermination(1, TimeUnit.MINUTES)) {
           LOG.warn("Timed out waiting for refresh executor to terminate");

Reply via email to