我想通过webhdfs调用来从安全节点使用Java检索文件。如何使用webhdfs从安全节点读取hdfs文件?
这是我在做什么 1.使用keytab登录(正常工作)。我得到一个Kerberos票据 2.现在,当我尝试调用下面的代码,它的作用是,它试图获得通过进行HTTPS调用delegationtoken和失败与401 https://mynode:50070/webhdfs/v1/?op=GETDELEGATIONTOKEN&user.name=myuser
下面是代码打开hdfs文件 FileSystem webFS = FileSystem.get(new URI(“swebhdfs://”+ domain +“myfile”),conf);
BufferedReader br = new BufferedReader(new InputStreamReader(webFS.open(new Path(“swebhdfs://”+ domain +“myfile”))));
我的问题是因为我有kerberos票证,我怎么能通过这一个UserGropupInformation对象?
感谢,