Pourquoi Hadoop FTPFileSystem.listStatus (chemin d'accès) ne fonctionne pas?

Question

Je veux transférer le fichier du serveur ftp vers hdfs. J'ai essayé cette méthode: FTP TO HDFS, le code de démonstration comme suit:

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); 

le ftpfs.listStatus(new Path("/")) ne fonctionne pas, il ne montre rien, mais le serveur ftp a deux répertoires et ftpfs.mkdirs(new Path("test")) fonctionnent bien, le résultat en cours d'exécution programme comme suit:

et le serveur ftp dirctory comme suit:

J'ai cherché sur google, mais je trouve un peu d'information. Je ne sais pas pourquoi. Si vous pouvez m'aider, je serai très reconnaissant, merci

Answer 1

Enfin, j'ai trouvé le problème où il est; Dans FTP Server, le mode de transfert de données est défini sur passif.

Je debuged le code source de FTPFileSystem, et je trouve qu'il n'a pas défini le mode FTP passif;

, je modifie le code correspondant de FTPFileSystem à ceci:

Relancez le programme:

et il fonctionne très bien: