Я получаю fileNotFoundException в указанной строке ниже. Ранее в Hadoop 1 это было функционально. Но теперь он выдает исключение FileNotFoundException
Path localManifestFolder;
Path localManifestPath = new Path("hdfs:///WordCount/write/manifest");
PrintWriter pw = null;
FileSystem fs = null;
try {
URI localHDFSManifestUri = new URI("
hdfs:///WordCount/write");
fs = FileSystem.get(localHDFSManifestUri, conf);
localManifestFolder = new Path("hdfs:///WordCount/write");
FileStatus[] listOfFiles = fs.listStatus(localManifestFolder); // Getting Error in this line
} catch (FileNotFoundException ex) {
throw ex;
}
Исключение:
java.io.FileNotFoundException: File hdfs:/WordCount/write does not exist.
Пожалуйста, скажите мне, почему это происходит