集群HA模式下的MapReduce代码设置
Configuration conf = HBaseConfiguration.create();
conf.set("hbase.zookeeper.quorum", "zk1:2181,zk2:2181,zk3:2181");
conf.set("hbase.zookeeper.property.clientPort", "2181");
conf.set("dfs.socket.timeout", "3600000");
conf.set("fs.defaultFS", "hdfs://clusters");
conf.set("dfs.nameservices", "clusters");
conf.set("dfs.ha.namenodes.masters", "hmaster1,hmaster2");
conf.set("dfs.namenode.rpc-address.masters.bigdata1", "namennode1:9000");
conf.set("dfs.namenode.rpc-address.masters.bigdata2", "namennode2:9000");
conf.set("dfs.client.failover.proxy.provider.masters", "org.apache.hadoop.hdfs.server.namenode.ha.ConfiguredFailoverProxyProvider");