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

HADOOP-15212. Add independent secret manager method for logging expired tokens. Contributed by Daryn Sharp.

Browse Source 
(cherry picked from commit 2dd960de983a30bf0d9ee957bdb09f825f9d40a3)
This commit is contained in:
Kihwal Lee 2018-02-06 15:38:32 -06:00
parent 43ea9a42d7
commit 39963d53df
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/security/token/delegation/AbstractDelegationTokenSecretManager.java
View File

@ -22,6 +22,7 @@
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.IOException; import java.io.IOException;
import java.security.MessageDigest; import java.security.MessageDigest;
import java.util.Collection;
import java.util.HashMap; import java.util.HashMap;
import java.util.HashSet; import java.util.HashSet;
import java.util.Iterator; import java.util.Iterator;
@ -627,6 +628,11 @@ private void removeExpiredToken() throws IOException {
} }
} }
// don't hold lock on 'this' to avoid edit log updates blocking token ops // don't hold lock on 'this' to avoid edit log updates blocking token ops
logExpireTokens(expiredTokens);
}
protected void logExpireTokens(
Collection<TokenIdent> expiredTokens) throws IOException {
for (TokenIdent ident : expiredTokens) { for (TokenIdent ident : expiredTokens) {
logExpireToken(ident); logExpireToken(ident);
LOG.info("Removing expired token " + formatTokenId(ident)); LOG.info("Removing expired token " + formatTokenId(ident));