big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Revert "HADOOP-17159 Ability for forceful relogin in UserGroupInformation class (#2197)"

Browse Source 
This reverts commit a932796d0c.
This commit is contained in:
Mingliang Liu 2020-08-26 10:41:10 -07:00
parent 931adbaa14
commit 5e52955112
No known key found for this signature in database
GPG Key ID: BC2FB8C6908A0C16
2 changed files with 7 additions and 64 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/security/UserGroupInformation.java
View File

@ -1232,26 +1232,7 @@ public void reloginFromKeytab() throws IOException {
reloginFromKeytab(false); reloginFromKeytab(false);
} }
/** private void reloginFromKeytab(boolean checkTGT) throws IOException {
* Force re-Login a user in from a keytab file. Loads a user identity from a
* keytab file and logs them in. They become the currently logged-in user.
* This method assumes that {@link #loginUserFromKeytab(String, String)} had
* happened already. The Subject field of this UserGroupInformation object is
* updated to have the new credentials.
*
* @param ignoreTimeElapsed Force re-login irrespective of the time of last
* login
* @throws IOException
* @throws KerberosAuthException on a failure
*/
@InterfaceAudience.Public
@InterfaceStability.Evolving
public void reloginFromKeytab(boolean ignoreTimeElapsed) throws IOException {
reloginFromKeytab(false, ignoreTimeElapsed);
}
private void reloginFromKeytab(boolean checkTGT, boolean ignoreTimeElapsed)
throws IOException {
if (!shouldRelogin() || !isFromKeytab()) { if (!shouldRelogin() || !isFromKeytab()) {
return; return;
} }
@ -1266,7 +1247,7 @@ private void reloginFromKeytab(boolean checkTGT, boolean ignoreTimeElapsed)
return; return;
} }
} }
relogin(login, ignoreTimeElapsed); relogin(login);
} }
/** /**
@ -1287,27 +1268,25 @@ public void reloginFromTicketCache() throws IOException {
if (login == null) { if (login == null) {
throw new KerberosAuthException(MUST_FIRST_LOGIN); throw new KerberosAuthException(MUST_FIRST_LOGIN);
} }
relogin(login, false); relogin(login);
} }
private void relogin(HadoopLoginContext login, boolean ignoreTimeElapsed) private void relogin(HadoopLoginContext login) throws IOException {
throws IOException {
// ensure the relogin is atomic to avoid leaving credentials in an // ensure the relogin is atomic to avoid leaving credentials in an
// inconsistent state. prevents other ugi instances, SASL, and SPNEGO // inconsistent state. prevents other ugi instances, SASL, and SPNEGO
// from accessing or altering credentials during the relogin. // from accessing or altering credentials during the relogin.
synchronized(login.getSubjectLock()) { synchronized(login.getSubjectLock()) {
// another racing thread may have beat us to the relogin. // another racing thread may have beat us to the relogin.
if (login == getLogin()) { if (login == getLogin()) {
unprotectedRelogin(login, ignoreTimeElapsed); unprotectedRelogin(login);
} }
} }
} }
private void unprotectedRelogin(HadoopLoginContext login, private void unprotectedRelogin(HadoopLoginContext login) throws IOException {
boolean ignoreTimeElapsed) throws IOException {
assert Thread.holdsLock(login.getSubjectLock()); assert Thread.holdsLock(login.getSubjectLock());
long now = Time.now(); long now = Time.now();
if (!hasSufficientTimeElapsed(now) && !ignoreTimeElapsed) { if (!hasSufficientTimeElapsed(now)) {
return; return;
} }
// register most recent relogin attempt // register most recent relogin attempt

36
hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/security/TestUGILoginFromKeytab.java
View File

@ -158,42 +158,6 @@ public void testUGIReLoginFromKeytab() throws Exception {
Assert.assertNotSame(login1, login2); Assert.assertNotSame(login1, login2);
} }
/**
* Force re-login from keytab using the MiniKDC and verify the UGI can
* successfully relogin from keytab as well.
*/
@Test
public void testUGIForceReLoginFromKeytab() throws Exception {
// Set this to false as we are testing force re-login anyways
UserGroupInformation.setShouldRenewImmediatelyForTests(false);
String principal = "foo";
File keytab = new File(workDir, "foo.keytab");
kdc.createPrincipal(keytab, principal);
UserGroupInformation.loginUserFromKeytab(principal, keytab.getPath());
UserGroupInformation ugi = UserGroupInformation.getLoginUser();
Assert.assertTrue("UGI should be configured to login from keytab",
ugi.isFromKeytab());
// Verify relogin from keytab.
User user = getUser(ugi.getSubject());
final long firstLogin = user.getLastLogin();
final LoginContext login1 = user.getLogin();
Assert.assertNotNull(login1);
// Sleep for 2 secs to have a difference between first and second login
Thread.sleep(2000);
// Force relogin from keytab
ugi.reloginFromKeytab(true);
final long secondLogin = user.getLastLogin();
final LoginContext login2 = user.getLogin();
Assert.assertTrue("User should have been able to relogin from keytab",
secondLogin > firstLogin);
Assert.assertNotNull(login2);
Assert.assertNotSame(login1, login2);
}
@Test @Test
public void testGetUGIFromKnownSubject() throws Exception { public void testGetUGIFromKnownSubject() throws Exception {
KerberosPrincipal principal = new KerberosPrincipal("user"); KerberosPrincipal principal = new KerberosPrincipal("user");