доступ к sftp с помощью api файловой системы hadoop - PullRequest
Новая
       37

доступ к sftp с помощью api файловой системы hadoop

0 голосов
/ 26 апреля 2019

доступ к sftp с использованием файловой системы hadoop не может остановить код приложения, приведенный ниже. 

public static void main(String[] args) {
    String sftpDir = "sftp://username:password@ftp-host/home/username/ftp/files/test";
    Configuration configuration = new Configuration();
    configuration.set("fs.sftp.impl", org.apache.hadoop.fs.sftp.SFTPFileSystem.class.getName());
    Path path = new Path(sftpDir);
    FileSystem fs;
    try {
        fs = path.getFileSystem(configuration);
        boolean exists = fs.exists(path);
        System.out.println("sftp exists: " + exists);
    } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
}

Замените имя пользователя / пароль действительным именем пользователя / паролем.После выполнения этого кода в Eclipse приложение не останавливается даже после того, как программа достигла конца.

Также попытался использовать fs.close ();но без толку.Будем очень благодарны за любые предложения по решению этой проблемы.

Примечание: если вместо sftp используется ftp, например: " ftp: // имя пользователя: пароль @ ftp-host / files / test", выполнение программы останавливается без проблем.

Заранее спасибо

...