分散キャッシュに追加されたファイルを読み取ろうとしているときに、Hadoop でこの例外が発生しました。奇妙なことに、ファイルは指定された場所に存在します。
java.io.FileNotFoundException: File does not exist: /tmp/hadoop-pera/mapred/local/taskTracker/distcache/-1517670662102870873_-1918892372_1898431787/localhost/work/output/temporalcentroids/centroids-iteration0-noOfClusters2/part-r-00000
を使用して仕事を始める前にファイルを追加しています
DistributedCache.addCacheFile(URI.create(args[2]), job.getConfiguration());
そして、マッパーの setup メソッドからファイルから読み取ろうとしています
DistributedCache.getLocalCacheFiles(conf);
前述のとおり、ファイルがローカル システム上にあることは確認できますが、例外がスローされます。
1台のコンピューターで、疑似分散モードでジョブを実行しています。
何か案は?
ありがとう