Hadoop створити файл у java викидає виняток: Mkdirs не вдалося створити - java, hadoop

Я намагаюся створити файл у Hadoop за допомогою клієнта Java (лише тестовий випадок). Виняток нижче було кинуто:

Exception in thread "main" java.io.IOException: Mkdirs failed to create /app2/speed (exists=false, cwd=file:/home/cpu-local/NetBeansProjects/hdoops)
at org.apache.hadoop.fs.ChecksumFileSystem.create(ChecksumFileSystem.java:450)
at org.apache.hadoop.fs.ChecksumFileSystem.create(ChecksumFileSystem.java:435)
at org.apache.hadoop.fs.FileSystem.create(FileSystem.java:909)
at org.apache.hadoop.fs.FileSystem.create(FileSystem.java:890)
at org.apache.hadoop.fs.FileSystem.create(FileSystem.java:787)
at org.apache.hadoop.fs.FileSystem.create(FileSystem.java:776)
at com.abc.hadoop.Test.main(Test.java:35)

Відповіді:

У зв'язку з тим, що не вдалося створити FileSystem через java-клієнт, все, що вам потрібно, - це встановити java-клієнт відповідною конфігурацією hadoop (у конфігурації файлу).

Configuration hadoopConfig = new Configuration();
hadoopConfig.set("fs.defaultFS", "hdfs://localhost:9000/");
hadoopConfig.set("fs.hdfs.impl", org.apache.hadoop.hdfs.DistributedFileSystem.class.getName());
hadoopConfig.set("fs.file.impl", org.apache.hadoop.fs.LocalFileSystem.class.getName());