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は、次のように：

Googleで検索しましたが、少しの情報が見つかりました。どうしてか分かりません。あなたが私を助けることができれば、私は非常に感謝します、ありがとう

Answer 1

最後に、私は問題があることを発見しました。 FTPサーバーでは、データ転送モードはパッシブに設定されています。

それから私はFTPFileSystemのソースコードをdebuged、と私はそれがFTPパッシブモードを設定していないことがわかりました。

再実行プログラム：

ので、私はこれにFTPFileSystemの関連コードを変更

をし、それが正常に動作します：