You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Copy file name to clipboardExpand all lines: hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/security/DelegationTokenRenewer.java
+12-1Lines changed: 12 additions & 1 deletion
Original file line number
Diff line number
Diff line change
@@ -301,13 +301,18 @@ public synchronized void addApplication(
301
301
*/
302
302
privateclassRenewalTimerTaskextendsTimerTask {
303
303
privateDelegationTokenToRenewdttr;
304
+
privatebooleancancelled = false;
304
305
305
306
RenewalTimerTask(DelegationTokenToRenewt) {
306
307
dttr = t;
307
308
}
308
309
309
310
@Override
310
-
publicvoidrun() {
311
+
publicsynchronizedvoidrun() {
312
+
if (cancelled) {
313
+
return;
314
+
}
315
+
311
316
Token<?> token = dttr.token;
312
317
try {
313
318
// need to use doAs so that http can find the kerberos tgt
@@ -331,6 +336,12 @@ public Long run() throws Exception {
0 commit comments