Skip to content

Commit

Permalink
fix comment
Browse files Browse the repository at this point in the history
  • Loading branch information
yuqi1129 committed Mar 21, 2024
1 parent b736571 commit 2665e38
Showing 1 changed file with 4 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,10 @@ public class CachedClientPool implements ClientPool<IMetaStoreClient, TException
.expireAfterAccess(evictionInterval, TimeUnit.MILLISECONDS)
.removalListener(
(ignored, value, cause) -> {
// We have closed the HiveClientPool that is manually removed from the cache.
// In fact, we have closed some HiveClientPools manually in the `close` method.
// to avoid closing it repeatedly, we add a judgment that if it has been closed,
// we do not need to close it anymore, please refer to the `close` method in
// `ClientPoolImpl`.
((HiveClientPool) value).close();
})
.scheduler(Scheduler.forScheduledExecutorService(scheduler))
Expand Down

0 comments on commit 2665e38

Please sign in to comment.