Skip to content

Commit f4751aa

Browse files
committed
HBASE-26525 Use unique thread name for group WALs
1 parent d1762f5 commit f4751aa

File tree

1 file changed

+2
-2
lines changed
  • hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal

1 file changed

+2
-2
lines changed

hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/AsyncFSWAL.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -237,8 +237,8 @@ public AsyncFSWAL(FileSystem fs, Abortable abortable, Path rootDir, String logDi
237237
ThreadPoolExecutor threadPool =
238238
new ThreadPoolExecutor(1, 1, 0L,
239239
TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>(),
240-
new ThreadFactoryBuilder().setNameFormat("AsyncFSWAL-%d-" + rootDir.toString()).
241-
setDaemon(true).build());
240+
new ThreadFactoryBuilder().setNameFormat("AsyncFSWAL-%d-prefix:" +
241+
(prefix == null ? "default" : prefix)).setDaemon(true).build());
242242
hasConsumerTask = () -> threadPool.getQueue().peek() == consumer;
243243
this.consumeExecutor = threadPool;
244244
}

0 commit comments

Comments
 (0)