Недопустимый символ в полномочиях по индексу 7: hdfs://localhost:9000 с помощью hadoop

Я пытаюсь подключиться к hdfs.

Configuration configuration = new Configuration();
configuration.set("fs.default.name", this.hdfsHost);
fs = FileSystem.get(configuration);

hdfsHost — 127.0.0.1:9000.

но получить это исключение в FileSystem.get();

У меня есть другой проект с тем же кодом, но работает хорошо. Может ли кто-нибудь дать какое-либо предложение? Большое спасибо

трек исключения:

Exception in thread "main" java.lang.IllegalArgumentException
at java.net.URI.create(URI.java:842)
at org.apache.hadoop.fs.FileSystem.getDefaultUri(FileSystem.java:103)
at org.apache.hadoop.fs.FileSystem.get(FileSystem.java:95)
at TransferToHadoop.TransferFiles.<init>(TransferFiles.java:50)             
at.TransferToHadoop.ScheduleTransferJobs.getTransferFiles(ScheduleTransferJobs.java:99)
at .TransferToHadoop.ScheduleTransferJobs.main(ScheduleTransferJobs.java:30)
 Caused by: java.net.URISyntaxException: Illegal character in authority at index 7: hdfs://localhost:9000  
at java.net.URI$Parser.fail(URI.java:2809)
at java.net.URI$Parser.parseAuthority(URI.java:3147)
at java.net.URI$Parser.parseHierarchical(URI.java:3058)
at java.net.URI$Parser.parse(URI.java:3014)
at java.net.URI.<init>(URI.java:578)
at java.net.URI.create(URI.java:840)
... 5 more

person lucky_start_izumi    schedule 16.12.2011    source источник


Ответы (3)


Попробуйте передать hdfsHost в качестве квалифицированного URL-адреса hdfs://127.0.0.1:9000 вместо 127.0.0.1:9000.

person Arnon Rotem-Gal-Oz    schedule 16.12.2011

Это может произойти, если в файле core-site.xml есть пробел в конце значения свойства для имени hdfs (fs.defaultFS).

person Binita Bharati    schedule 03.10.2015

Свяжите имя хоста с соответствующим IP-адресом на обоих серверах, то есть как на клиенте, так и на сервере в файле /etc/hosts

person Saroj    schedule 27.03.2015