Hadoop: метод FileSystem.get throws IOException

Question

Я новичок в Hadoop. Я пытаюсь запустить ниже простого кода, но продолжаю получать сообщение IOException с сообщением No FileSystem for scheme: file. Я запускаю единый узел Hadoop 2.7.0 на Ubuntu. Я подозреваю, что это проблема конфигурации. Любая быстрая помощь будет высоко оценена. Я искал StackOverflow, но не нашел подходящего ответа.

// Check if a file exists 
public boolean exists() throws IOException { 
    boolean isExists = false;  
    try{ 
     FileSystem hdfs = FileSystem.get(new Configuration()); 
     Path newPath = new Path(hdfsRoot,file.getName()); 
     isExists = hdfs.exists(newPath); 
     hdfs.close();   
    }catch(IOException ex){ 
     // log exception and then re-throw 
     throw ex; 
    } 
    return isExists; 
} 

Это метод FileSystem.get, который бросает IOException.

Answer 1

// Check if a file exists 
     public boolean exists() throws IOException { 
      boolean isExists = false;  
      try{ 
       FileSystem hdfs = FileSystem.get(new URI("hdfs://localhost:9000"),new Configuration()); 
       Path newPath = new Path("/test.txt"); 
       isExists = hdfs.exists(newPath); 
       hdfs.close();   
      }catch(IOException ex){ 
       // log exception and then re-throw 
       throw ex; 
      } 
      return isExists; 
     } 

Примечание - hdfsRoot должен быть hdfs://localhost:9000 и file.getName() должно быть имя вашего файла. означает, что ваше местоположение файла должно быть HDFS: // локальный: 9000/test.txt

дайте мне знать, если не работать