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");