Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
languagejava
Configuration conf = new Configuration();
        conf.set("fs.hdfs.impl", org.apache.hadoop.hdfs.DistributedFileSystem.class.getName());
 
      conf.set("fs.file.impl", org.apache.hadoop.fs.LocalFileSystem.class.getName());
  
     conf.set("fs.defaultFS", "hdfs://cluster");
   
    conf.set("fs.default.name", conf.get("fs.defaultFS"));
    
   conf.set("dfs.nameservices", "cluster");
     
  conf.set("dfs.ha.namenodes.cluster", "nn1,nn2");
      
 conf.set("dfs.namenode.rpc-address.cluster.nn1", "<url_of_your_namenode_1>:8020");
       
conf.set("dfs.namenode.rpc-address.cluster.nn2", "<url_of_your_namenode_2>:8020");
       
conf.set("dfs.client.failover.proxy.provider.cluster","org.apache.hadoop.hdfs.server.namenode.ha.ConfiguredFailoverProxyProvider");

...