diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/security/DelegationTokenRenewer.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/security/DelegationTokenRenewer.java index b4da08f52fe..7dfc0120d59 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/security/DelegationTokenRenewer.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/security/DelegationTokenRenewer.java @@ -228,6 +228,11 @@ private void processDelegationTokenRenewerEvent( futures.put(evt, future); } else { pendingEventQueue.add(evt); + int qSize = pendingEventQueue.size(); + if (qSize != 0 && qSize % 1000 == 0) { + LOG.info("Size of pending " + + "DelegationTokenRenewerEvent queue is " + qSize); + } } } finally { serviceStateLock.readLock().unlock();