java 操做hdfs(鏈接HDFS)

 

 

FileSystem fs = null;
    Configuration conf = null;
    @Before
    public void init() throws Exception{
        
        conf = new Configuration();
//        fs=FileSystem.get(conf);
//        conf.set("fs.defaultFS", "hdfs://node2:8020");
        
        //拿到一個文件系統操做的客戶端實例對象
        /*fs = FileSystem.get(conf);*/
        //能夠直接傳入 uri和用戶身份
        fs = FileSystem.get(new URI("hdfs://node2:8020"),conf,"root"); //最後一個參數爲用戶名
    }

    @After
    public void end(){
        try {
            fs.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

 

1注意端口號是否正確

2須要鏈接到active狀態的namenode

3，hadoop用戶名是否正確