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

HADOOP-15864. Job submitter / executor fail when SBN domain name can not resolved. Contributed by He Xiaoqiao. 

(cherry picked from commit fb2b72e6fc)
(cherry picked from commit fd02c501c0)
This commit is contained in:
Wei-Chiu Chuang 2018-10-25 09:33:31 -07:00
parent 4b1f2ecd4c
commit ef9f8ca13d
2 changed files with 28 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/security/SecurityUtil.java
View File

@ -421,7 +421,7 @@ public final class SecurityUtil {
*/ */
public static void setTokenService(Token<?> token, InetSocketAddress addr) { public static void setTokenService(Token<?> token, InetSocketAddress addr) {
Text service = buildTokenService(addr); Text service = buildTokenService(addr);
if (token != null) { if (token != null && service != null) {
token.setService(service); token.setService(service);
if (LOG.isDebugEnabled()) { if (LOG.isDebugEnabled()) {
LOG.debug("Acquired token "+token); // Token#toString() prints service LOG.debug("Acquired token "+token); // Token#toString() prints service
@ -441,9 +441,10 @@ public final class SecurityUtil {
String host = null; String host = null;
if (useIpForTokenService) { if (useIpForTokenService) {
if (addr.isUnresolved()) { // host has no ip address if (addr.isUnresolved()) { // host has no ip address
throw new IllegalArgumentException( LOG.warn("unable to resolve host name " + addr
new UnknownHostException(addr.getHostName()) + ". Failure to construct a correct token service "
); + "name may result in operation failures");
return null;
} }
host = addr.getAddress().getHostAddress(); host = addr.getAddress().getHostAddress();
} else { } else {

23
hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/ha/TestDelegationTokensWithHA.java
View File

@ -332,6 +332,29 @@ public class TestDelegationTokensWithHA {
} }
} }
@Test(timeout = 300000)
public void testHAUtilClonesDTsDomainNameResolvedFail() throws Exception {
final Token<DelegationTokenIdentifier> token =
getDelegationToken(fs, "JobTracker");
UserGroupInformation ugi = UserGroupInformation.createRemoteUser("test");
URI haUri = new URI("hdfs://my-ha-uri/");
token.setService(HAUtilClient.buildTokenServiceForLogicalUri(haUri,
HdfsConstants.HDFS_URI_SCHEME));
ugi.addToken(token);
Collection<InetSocketAddress> nnAddrs = new HashSet<InetSocketAddress>();
nnAddrs.add(new InetSocketAddress("domainname.doesnot.exist",
nn0.getNameNodeAddress().getPort()));
nnAddrs.add(new InetSocketAddress("localhost",
nn1.getNameNodeAddress().getPort()));
HAUtilClient.cloneDelegationTokenForLogicalUri(ugi, haUri, nnAddrs);
Collection<Token<? extends TokenIdentifier>> tokens = ugi.getTokens();
assertEquals(3, tokens.size());
}
/** /**
* HDFS-3062: DistributedFileSystem.getCanonicalServiceName() throws an * HDFS-3062: DistributedFileSystem.getCanonicalServiceName() throws an
* exception if the URI is a logical URI. This bug fails the combination of * exception if the URI is a logical URI. This bug fails the combination of