YARN-2972. DelegationTokenRenewer thread pool never expands. Contributed by Jason Lowe

This commit is contained in:
Junping Du 2014-12-17 17:40:00 -08:00
parent 3b173d9517
commit 2b4b0e8847
2 changed files with 4 additions and 1 deletions

View File

@ -138,6 +138,9 @@ Release 2.7.0 - UNRELEASED
YARN-2762. Fixed RMAdminCLI to trim and check node-label related arguments YARN-2762. Fixed RMAdminCLI to trim and check node-label related arguments
before sending to RM. (Rohith Sharmaks via jianhe) before sending to RM. (Rohith Sharmaks via jianhe)
YARN-2972. DelegationTokenRenewer thread pool never expands. (Jason Lowe
via junping_du)
OPTIMIZATIONS OPTIMIZATIONS
BUG FIXES BUG FIXES

View File

@ -148,7 +148,7 @@ public class DelegationTokenRenewer extends AbstractService {
.setNameFormat("DelegationTokenRenewer #%d") .setNameFormat("DelegationTokenRenewer #%d")
.build(); .build();
ThreadPoolExecutor pool = ThreadPoolExecutor pool =
new ThreadPoolExecutor((5 < nThreads ? 5 : nThreads), nThreads, 3L, new ThreadPoolExecutor(nThreads, nThreads, 3L,
TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>()); TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>());
pool.setThreadFactory(tf); pool.setThreadFactory(tf);
pool.allowCoreThreadTimeOut(true); pool.allowCoreThreadTimeOut(true);