HDFS-7798. Checkpointing failure caused by shared KerberosAuthenticator. (Chengbing Liu via yliu)
This commit is contained in:
parent
9729b244de
commit
500e6a0f46
@ -957,6 +957,9 @@ Release 2.7.0 - UNRELEASED
|
|||||||
HDFS-4625. BKJM doesn't take advantage of speculative reads. (Rakesh R
|
HDFS-4625. BKJM doesn't take advantage of speculative reads. (Rakesh R
|
||||||
via aajisaka)
|
via aajisaka)
|
||||||
|
|
||||||
|
HDFS-7798. Checkpointing failure caused by shared KerberosAuthenticator.
|
||||||
|
(Chengbing Liu via yliu)
|
||||||
|
|
||||||
BREAKDOWN OF HDFS-7584 SUBTASKS AND RELATED JIRAS
|
BREAKDOWN OF HDFS-7584 SUBTASKS AND RELATED JIRAS
|
||||||
|
|
||||||
HDFS-7720. Quota by Storage Type API, tools and ClientNameNode
|
HDFS-7720. Quota by Storage Type API, tools and ClientNameNode
|
||||||
|
@ -49,9 +49,6 @@
|
|||||||
public class URLConnectionFactory {
|
public class URLConnectionFactory {
|
||||||
private static final Log LOG = LogFactory.getLog(URLConnectionFactory.class);
|
private static final Log LOG = LogFactory.getLog(URLConnectionFactory.class);
|
||||||
|
|
||||||
/** SPNEGO authenticator */
|
|
||||||
private static final KerberosUgiAuthenticator AUTH = new KerberosUgiAuthenticator();
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Timeout for socket connects and reads
|
* Timeout for socket connects and reads
|
||||||
*/
|
*/
|
||||||
@ -161,8 +158,8 @@ public URLConnection openConnection(URL url, boolean isSpnego)
|
|||||||
}
|
}
|
||||||
UserGroupInformation.getCurrentUser().checkTGTAndReloginFromKeytab();
|
UserGroupInformation.getCurrentUser().checkTGTAndReloginFromKeytab();
|
||||||
final AuthenticatedURL.Token authToken = new AuthenticatedURL.Token();
|
final AuthenticatedURL.Token authToken = new AuthenticatedURL.Token();
|
||||||
return new AuthenticatedURL(AUTH, connConfigurator).openConnection(url,
|
return new AuthenticatedURL(new KerberosUgiAuthenticator(),
|
||||||
authToken);
|
connConfigurator).openConnection(url, authToken);
|
||||||
} else {
|
} else {
|
||||||
if (LOG.isDebugEnabled()) {
|
if (LOG.isDebugEnabled()) {
|
||||||
LOG.debug("open URL connection");
|
LOG.debug("open URL connection");
|
||||||
|
Loading…
Reference in New Issue
Block a user