You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2024/05/09 07:54:32 UTC
(pulsar) 03/03: [improve][offload] Replace usage of shaded class in OffsetsCache (#22683)
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 395a88632380c75bca140765bfa42d80f375f8f8
Author: Lari Hotari <lh...@apache.org>
AuthorDate: Thu May 9 10:45:29 2024 +0300
[improve][offload] Replace usage of shaded class in OffsetsCache (#22683)
---
.../apache/bookkeeper/mledger/offload/jcloud/impl/OffsetsCache.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/OffsetsCache.java b/tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/OffsetsCache.java
index fa13afa8ff0..6651b199e4e 100644
--- a/tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/OffsetsCache.java
+++ b/tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/OffsetsCache.java
@@ -20,7 +20,7 @@ package org.apache.bookkeeper.mledger.offload.jcloud.impl;
import com.google.common.cache.Cache;
import com.google.common.cache.CacheBuilder;
-import io.grpc.netty.shaded.io.netty.util.concurrent.DefaultThreadFactory;
+import com.google.common.util.concurrent.ThreadFactoryBuilder;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
@@ -49,7 +49,7 @@ public class OffsetsCache implements AutoCloseable {
.build();
cacheEvictionExecutor =
Executors.newSingleThreadScheduledExecutor(
- new DefaultThreadFactory("jcloud-offsets-cache-eviction"));
+ new ThreadFactoryBuilder().setNameFormat("jcloud-offsets-cache-eviction").build());
int period = Math.max(CACHE_TTL_SECONDS / 2, 1);
cacheEvictionExecutor.scheduleAtFixedRate(() -> {
entryOffsetsCache.cleanUp();