This is an automated email from the ASF dual-hosted git repository.
zhaocong pushed a commit to branch branch-3.3
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-3.3 by this push:
new 32be8933a82 [improve][offload] Replace usage of shaded class in
OffsetsCache (#22683)
32be8933a82 is described below
commit 32be8933a821583597fca657171152ac664902b7
Author: Lari Hotari <[email protected]>
AuthorDate: Thu May 9 13:04:12 2024 +0300
[improve][offload] Replace usage of shaded class in OffsetsCache (#22683)
(cherry picked from commit 03a4995a161face8998eadbbf9baaf2d4f55e63a)
---
.../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();