Исключение Geting при использовании DistributedCache в Hadoop

Question

Я использовал нижеприведенный код для распределенного кэширования в основном классе.

job.addCacheFile(new URI(args[2])); 

Ниже упомянутый код относится к классу уменьшения.

@Override 
     protected void setup(Reducer<LongWritable, Text, Text, Text>.Context context) throws IOException, InterruptedException { 
      super.setup(context); 
      URI[] paths = context.getCacheFiles(); 
      if (paths.length > 0) { 
       loadDeliveryStatusCodes(paths[0].toString()); 
      } 
     } 
     private void loadDeliveryStatusCodes(String file) { 
      String strRead; 
      BufferedReader reader = null; 
      try { 
       reader = new BufferedReader(new FileReader("./some")); 
       while ((strRead = reader.readLine()) != null) { 
        String splitarray[] = strRead.split(","); 
        deliveryCodesMap.put(splitarray[0].trim(), splitarray[1].trim()); 
       } 
      } catch (FileNotFoundException e) { 
       e.printStackTrace(); 
      } catch (IOException e) { 
       e.printStackTrace(); 
      } finally { 
       try { 
        reader.close(); 
       } catch (IOException e) { 
        e.printStackTrace(); 
       } 
      } 
     } 

Я получаю приведенное ниже исключение.

@@@@@@@@/user/DeliveryStatusCodes.txt 1 
java.io.FileNotFoundException: ./some (No such file or directory) 
    at java.io.FileInputStream.open0(Native Method) 
    at java.io.FileInputStream.open(FileInputStream.java:195) 
    at java.io.FileInputStream.<init>(FileInputStream.java:138) 
    at java.io.FileInputStream.<init>(FileInputStream.java:93) 
    at java.io.FileReader.<init>(FileReader.java:58) 
    at com.hadoop.intellipaat.UserSMSDeliveryJob$USERNameSMSStatusCodeMapper.loadDeliveryStatusCodes(UserSMSDeliveryJob.java:95) 

Ваша помощь спасет мой день. Спасибо.

Answer 1

Похоже, вы пропустили #some с конца вашего args[2] .На данный момент у вас есть /user/DeliveryStatusCodes.txt, но вы должны иметь

/user/DeliveryStatusCodes.txt#some 

Без него FileReader буквально ищет ./some, который, конечно, не будет.

Или вы можете пропустить псевдоним (это необязательно) и написать

new FileReader("/user/DeliveryStatusCodes.txt")