HDFS-4780. Use the correct relogin method for services. Contributed by Robert Parker.

git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/trunk@1486974 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Kihwal Lee 2013-05-28 15:47:56 +00:00
parent 9a43df8e5a
commit 45b9d19f9d
5 changed files with 8 additions and 5 deletions

View File

@ -891,6 +891,9 @@ Release 2.0.5-beta - UNRELEASED
HDFS-4825. webhdfs / httpfs tests broken because of min block size change.
(Andrew Wang via suresh)
HDFS-4780. Use the correct relogin method for services. (Robert Parker via
kihwal)
BREAKDOWN OF HDFS-347 SUBTASKS AND RELATED JIRAS
HDFS-4353. Encapsulate connections to peers in Peer and PeerServer classes.

View File

@ -251,7 +251,7 @@ public class HftpFileSystem extends FileSystem
) throws IOException {
try {
//Renew TGT if needed
ugi.reloginFromKeytab();
ugi.checkTGTAndReloginFromKeytab();
return ugi.doAs(new PrivilegedExceptionAction<Token<?>>() {
@Override
public Token<?> run() throws IOException {
@ -704,7 +704,7 @@ public class HftpFileSystem extends FileSystem
public long renew(Token<?> token,
Configuration conf) throws IOException {
// update the kerberos credentials, if they are coming from a keytab
UserGroupInformation.getLoginUser().reloginFromKeytab();
UserGroupInformation.getLoginUser().checkTGTAndReloginFromKeytab();
// use http to renew the token
InetSocketAddress serviceAddr = SecurityUtil.getTokenServiceAddr(token);
return

View File

@ -157,7 +157,7 @@ public class GetImageServlet extends HttpServlet {
// We may have lost our ticket since last checkpoint, log in again, just in case
if (UserGroupInformation.isSecurityEnabled()) {
UserGroupInformation.getCurrentUser().reloginFromKeytab();
UserGroupInformation.getCurrentUser().checkTGTAndReloginFromKeytab();
}
// issue a HTTP get request to download the new fsimage

View File

@ -371,7 +371,7 @@ public class SecondaryNameNode implements Runnable {
try {
// We may have lost our ticket since last checkpoint, log in again, just in case
if(UserGroupInformation.isSecurityEnabled())
UserGroupInformation.getCurrentUser().reloginFromKeytab();
UserGroupInformation.getCurrentUser().checkTGTAndReloginFromKeytab();
long now = Time.now();

View File

@ -262,7 +262,7 @@ public class StandbyCheckpointer {
try {
// We may have lost our ticket since last checkpoint, log in again, just in case
if (UserGroupInformation.isSecurityEnabled()) {
UserGroupInformation.getCurrentUser().reloginFromKeytab();
UserGroupInformation.getCurrentUser().checkTGTAndReloginFromKeytab();
}
long now = now();