Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- Configuration conf = new Configuration();
- conf.set("fs.defaultFS","swebhdfs://one.hdp:50470");
- FileSystem fs = FileSystem.get(conf);
- FileStatus[] fsStatus = fs.listStatus(new Path("/"));
- for(int i = 0; i < fsStatus.length; i++){
- System.out.println(fsStatus[i].getPath().toString());
- }
- private static String username = "hdfs-user";
- private static char[] password = "hadoop".toCharArray();
- public static LoginContext kinit() throws LoginException {
- LoginContext lc = new LoginContext(HdfsMain.class.getSimpleName(), new CallbackHandler() {
- public void handle(Callback[] callbacks) throws IOException, UnsupportedCallbackException {
- for(Callback c : callbacks){
- if(c instanceof NameCallback)
- ((NameCallback) c).setName(username);
- if(c instanceof PasswordCallback)
- ((PasswordCallback) c).setPassword(password);
- }
- }});
- lc.login();
- return lc;
- }
- HdfsMain {
- com.sun.security.auth.module.Krb5LoginModule required client=TRUE;
- };
- Configuration conf = new Configuration();
- conf.set("fs.defaultFS", "hdfs://one.hdp:8020");
- conf.set("hadoop.security.authentication", "kerberos");
- UserGroupInformation.setConfiguration(conf);
- LoginContext lc = kinit();
- UserGroupInformation.loginUserFromSubject(lc.getSubject());
- FileSystem fs = FileSystem.get(conf);
- FileStatus[] fsStatus = fs.listStatus(new Path("/"));
- for(int i = 0; i < fsStatus.length; i++){
- System.out.println(fsStatus[i].getPath().toString());
- }
- Caused by: KrbException: null (68)
- at sun.security.krb5.KrbAsRep.<init>(KrbAsRep.java:76)
- at sun.security.krb5.KrbAsReqBuilder.send(KrbAsReqBuilder.java:316)
- at sun.security.krb5.KrbAsReqBuilder.action(KrbAsReqBuilder.java:361)
- at com.sun.security.auth.module.Krb5LoginModule.attemptAuthentication(Krb5LoginModule.java:766)
- ... 15 more
- Caused by: KrbException: Identifier doesn't match expected value (906)
- at sun.security.krb5.internal.KDCRep.init(KDCRep.java:140)
- at sun.security.krb5.internal.ASRep.init(ASRep.java:64)
- at sun.security.krb5.internal.ASRep.<init>(ASRep.java:59)
- at sun.security.krb5.KrbAsRep.<init>(KrbAsRep.java:60)
- ... 18 more
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement