Advertisement

Java连接HDFS+Kerberos配置参数示例

阅读量:

完成Kerberos配置之后,与HDFS进行连接时所采用的参数设置如下:

复制代码
 private void confLoad() throws IOException {

    
 		conf = new Configuration();
    
 		conf.clear();
    
 		conf.set("hadoop.security.authentication", "kerberos");
    
 		conf.set("fs.defaultFS", "hdfs://IP:8020");
    
 		//conf.set("hadoop.rpc.protection", "authentication");
    
 		conf.set("hadoop.rpc.protection", "privacy");
    
 		conf.set("dfs.data.transfer.protection", "integrity");
    
 	}
    
    
    
    

hadoop.rpc.protection参数必须与集群的配置保持一致,否则将出现以下异常:

Exception in thread "main" java.io.IOException: 本地异常处理失败:java.io.IOExceptio

全部评论 (0)

还没有任何评论哟~