(hbase) branch branch-2.5 updated: HBASE-26525 Use unique thread name for group WALs (#3903)(#5895)

[zhangduo]

This is an automated email from the ASF dual-hosted git repository.

zhangduo pushed a commit to branch branch-2.5
in repository https://gitbox.apache.org/repos/asf/hbase.git


The following commit(s) were added to refs/heads/branch-2.5 by this push:
     new c7248ab5e4b HBASE-26525 Use unique thread name for group WALs 
(#3903)(#5895)
c7248ab5e4b is described below

commit c7248ab5e4bccb8737a09739cd94eb020a632238
Author: szucsvillo <81696283+szucsvi...@users.noreply.github.com>
AuthorDate: Tue May 21 10:28:45 2024 +0200

    HBASE-26525 Use unique thread name for group WALs (#3903)(#5895)
    
    Change-Id: I351a7dcc8da8620ef472753f1bbdbb5a209276cf
    
    Co-authored-by: haxiaolin <haxiao...@apache.org>
    Signed-off-by: Duo Zhang <zhang...@apache.org>
---
 .../java/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.java | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.java
 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.java
index f13160a549a..c4ccb21d2a7 100644
--- 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.java
+++ 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.java
@@ -234,9 +234,11 @@ public class AsyncFSWAL extends AbstractFSWAL<AsyncWriter> 
{
         hasConsumerTask = () -> false;
       }
     } else {
-      ThreadPoolExecutor threadPool = new ThreadPoolExecutor(1, 1, 0L, 
TimeUnit.MILLISECONDS,
-        new LinkedBlockingQueue<Runnable>(), new ThreadFactoryBuilder()
-          .setNameFormat("AsyncFSWAL-%d-" + 
rootDir.toString()).setDaemon(true).build());
+      ThreadPoolExecutor threadPool =
+        new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, new 
LinkedBlockingQueue<Runnable>(),
+          new ThreadFactoryBuilder().setNameFormat("AsyncFSWAL-%d-" + 
rootDir.toString()
+            + "-prefix:" + (prefix == null ? "default" : prefix).replace("%", 
"%%")).setDaemon(true)
+            .build());
       hasConsumerTask = () -> threadPool.getQueue().peek() == consumer;
       this.consumeExecutor = threadPool;
     }