Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

YARN-264. y.s.rm.DelegationTokenRenewer attempts to renew token even after removing an app. (kkambatl via tucu) 

git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/trunk@1421575 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Alejandro Abdelnur 2012-12-13 22:16:29 +00:00
parent f6f7152995
commit be8ef2ec33
2 changed files with 15 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hadoop-yarn-project/CHANGES.txt
View File

@ -125,6 +125,9 @@ Release 2.0.3-alpha - Unreleased
YARN-267. Fix fair scheduler web UI. (Sandy Ryza via tomwhite) YARN-267. Fix fair scheduler web UI. (Sandy Ryza via tomwhite)
YARN-264. y.s.rm.DelegationTokenRenewer attempts to renew token even
after removing an app. (kkambatl via tucu)
Release 2.0.2-alpha - 2012-09-07 Release 2.0.2-alpha - 2012-09-07
INCOMPATIBLE CHANGES INCOMPATIBLE CHANGES

13
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/security/DelegationTokenRenewer.java
View File

@ -301,13 +301,18 @@ public class DelegationTokenRenewer extends AbstractService {
*/ */
private class RenewalTimerTask extends TimerTask { private class RenewalTimerTask extends TimerTask {
private DelegationTokenToRenew dttr; private DelegationTokenToRenew dttr;
private boolean cancelled = false;
RenewalTimerTask(DelegationTokenToRenew t) { RenewalTimerTask(DelegationTokenToRenew t) {
dttr = t; dttr = t;
} }
@Override @Override
public void run() { public synchronized void run() {
if (cancelled) {
return;
}
Token<?> token = dttr.token; Token<?> token = dttr.token;
try { try {
// need to use doAs so that http can find the kerberos tgt // need to use doAs so that http can find the kerberos tgt
@ -331,6 +336,12 @@ public class DelegationTokenRenewer extends AbstractService {
removeFailedDelegationToken(dttr); removeFailedDelegationToken(dttr);
} }
} }
@Override
public synchronized boolean cancel() {
cancelled = true;
return super.cancel();
}
} }
/** /**