|
@@ -29,6 +29,7 @@ import java.net.URI;
|
|
|
|
|
|
import org.apache.hadoop.conf.Configuration;
|
|
|
import org.apache.hadoop.fs.FileSystem;
|
|
|
+import org.apache.hadoop.hdfs.DFSUtilClient;
|
|
|
import org.apache.hadoop.hdfs.MiniDFSCluster;
|
|
|
import org.apache.hadoop.hdfs.server.namenode.NameNode;
|
|
|
import org.apache.hadoop.mapred.JobConf;
|
|
@@ -111,9 +112,8 @@ public class TestMRCredentials {
|
|
|
Configuration jobConf = new JobConf(mrCluster.getConfig());
|
|
|
|
|
|
// provide namenodes names for the job to get the delegation tokens for
|
|
|
- //String nnUri = dfsCluster.getNameNode().getUri(namenode).toString();
|
|
|
NameNode nn = dfsCluster.getNameNode();
|
|
|
- URI nnUri = NameNode.getUri(nn.getNameNodeAddress());
|
|
|
+ URI nnUri = DFSUtilClient.getNNUri(nn.getNameNodeAddress());
|
|
|
jobConf.set(JobContext.JOB_NAMENODES, nnUri + "," + nnUri.toString());
|
|
|
|
|
|
|