Revert "HBASE-22930 Set unique name to longCompactions/shortCompactions threads (#548)"
This reverts commit b6d17f6b44
.
This commit is contained in:
parent
b6d17f6b44
commit
352240c048
|
@ -119,22 +119,19 @@ public class CompactSplit implements CompactionRequester, PropagatingConfigurati
|
|||
Preconditions.checkArgument(largeThreads > 0 && smallThreads > 0);
|
||||
|
||||
final String n = Thread.currentThread().getName();
|
||||
StealJobQueue<Runnable> stealJobQueue = new StealJobQueue<Runnable>(COMPARATOR);
|
||||
|
||||
AtomicInteger longCompactionThreadCounter = new AtomicInteger(0);
|
||||
this.longCompactions =
|
||||
new ThreadPoolExecutor(largeThreads, largeThreads, 60, TimeUnit.SECONDS, stealJobQueue,
|
||||
new ThreadFactoryBuilder().setNameFormat(n + "-longCompactions-"
|
||||
+ longCompactionThreadCounter.getAndIncrement() + "-" + System.currentTimeMillis())
|
||||
StealJobQueue<Runnable> stealJobQueue = new StealJobQueue<Runnable>(COMPARATOR);
|
||||
this.longCompactions = new ThreadPoolExecutor(largeThreads, largeThreads, 60,
|
||||
TimeUnit.SECONDS, stealJobQueue,
|
||||
new ThreadFactoryBuilder()
|
||||
.setNameFormat(n + "-longCompactions-" + System.currentTimeMillis())
|
||||
.setDaemon(true).build());
|
||||
this.longCompactions.setRejectedExecutionHandler(new Rejection());
|
||||
this.longCompactions.prestartAllCoreThreads();
|
||||
|
||||
AtomicInteger shortCompactionThreadCounter = new AtomicInteger(0);
|
||||
this.shortCompactions = new ThreadPoolExecutor(smallThreads, smallThreads, 60, TimeUnit.SECONDS,
|
||||
stealJobQueue.getStealFromQueue(),
|
||||
new ThreadFactoryBuilder().setNameFormat(n + "-shortCompactions-"
|
||||
+ shortCompactionThreadCounter.getAndIncrement() + "-" + System.currentTimeMillis())
|
||||
this.shortCompactions = new ThreadPoolExecutor(smallThreads, smallThreads, 60,
|
||||
TimeUnit.SECONDS, stealJobQueue.getStealFromQueue(),
|
||||
new ThreadFactoryBuilder()
|
||||
.setNameFormat(n + "-shortCompactions-" + System.currentTimeMillis())
|
||||
.setDaemon(true).build());
|
||||
this.shortCompactions.setRejectedExecutionHandler(new Rejection());
|
||||
this.splits = (ThreadPoolExecutor) Executors.newFixedThreadPool(splitThreads,
|
||||
|
|
Loading…
Reference in New Issue