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

Reply via email to