Hadoop FTPFileSystem.listStatus (경로 경로)가 작동하지 않는 이유는 무엇입니까?

Question

ftp 서버에서 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 TO HDFS를, 데모 코드는 다음과 같습니다 :

및 FTP 서버 dirctory는 다음과 같이

,

Google에서 검색했지만 정보가 조금 있습니다. 나는 이유를 모른다. 당신이 나를 도울 수 있다면, 나는 매우 감사 할 것입니다, 감사합니다

Answer 1

마지막으로, 나는 그것이 어디에 문제인지를 발견했습니다. FTP 서버에서 데이터 전송 모드는 수동으로 설정됩니다.

은 그 때 나는 FTPFileSystem의 소스 코드를 디버그하는, 그리고 난 그것이 FTP 수동 모드를 설정하지 않은 것을 발견;

다시 실행 프로그램 :

그래서,이에 FTPFileSystem의 관련 코드를 수정

을하고 그것을 잘 작동합니다 :