爲什麼Hadoop FTPFileSystem.listStatus（路徑路徑）不起作用？

Question

我想將文件從ftp服務器傳輸到hdfs。這個方法我試過：FTP TO HDFS，演示代碼如下：

Configuration conf = new Configuration(); 
    FTPFileSystem ftpfs = new FTPFileSystem(); 
    ftpfs.setConf(conf); 
    ftpfs.initialize(new URI(ftpConnectStr), conf); 

    Path homeDirectory = ftpfs.getHomeDirectory(); 
    System.out.println(homeDirectory.toString()); 

    FileStatus[] fileStatuses = ftpfs.listStatus(new Path("/")); 
    for(FileStatus fileStatus : fileStatuses){ 
     System.out.println(fileStatuses.length); 
     System.out.println(fileStatus.toString()); 
    } 

    boolean test = ftpfs.mkdirs(new Path("test")); 
    System.out.println(test); 

的ftpfs.listStatus(new Path("/"))不起作用，它說明不了什麼，但FTP服務器有兩個目錄和ftpfs.mkdirs(new Path("test"))做工精細，運行結果如下方案：

和FTP服務器dirctory如下：

我在谷歌搜索，但找到一些信息。我不知道爲什麼。如果你能幫助我，我將非常感謝，謝謝

Answer 1

最後，我發現問題在哪裏;在FTP服務器中，數據轉發模式設置爲被動模式。

然後我debuged FTPFileSystem的源代碼，和我發現它沒有設置FTP被動模式;

所以，我修改FTPFileSystem的相關代碼如下：

重新運行該程序：

，它工作正常：