hdaoop2.x (CDH4、5)下使用DFS Client(包含HA)
FileSystem fs = FileSystem.get(URI.create("hdfs://<nn_ip>:<nn_port>"), new Configuration());
Configuration conf = new Configuration();conf.set("fs.default.name", "hdfs://<nn_ip>:<nn_port>");FileSystem fs = FileSystem.get(conf);
<property> <name>dfs.client.failover.proxy.provider.<your_nameservices></name> <value>org.apache.hadoop.hdfs.server.namenode.ha.ConfiguredFailoverProxyProvider</value> </property>
?
方法二:代码嵌入配置
使用1.2配置方式,并设置如下值:fs.default.name(hadoop2.0兼容1.0该配置项名称,也可使用"fs.defaultFS")dfs.nameservicesdfs.ha.namenodes.<your_nameservices>dfs.namenode.rpc-address.<your_nameservices>.xxxdfs.namenode.rpc-address.<your_nameservices>.yyydfs.client.failover.proxy.provider.<your_nameservices>HA配置总结??? 方法一的优点是不需要修改代码,缺点是要维护配置文件,方法二要修改系统代码,但不需要维护配置文件
?
-end
?
?