DistributedCache.addFileToClassPath(Path file、Configuration conf)メソッドを使用して、一連のjarを分散キャッシュに追加し、クラスター全体でマップリデュースジョブに依存関係を利用できるようにしました。ここで、これらのjarをすべてキャッシュから削除してクリーンを開始し、そこに正しいjarバージョンがあることを確認したいと思います。ファイルをキャッシュに追加するコードをコメントアウトし、hdfsでコピーした場所からファイルを削除しました。問題は、map reduceジョブがClassNotFound例外をスローしていないため、jarがまだクラスパスにあるように見えることです。サービスを再起動せずにこのキャッシュをフラッシュする方法はありますか?
編集:その後、次のフォルダーをフラッシュしました:/ var / lib / hadoop-hdfs / cache / mapred / mapred / local / taskTracker /distcache/。それはそれを解決しませんでした。ジョブはまだ参照を見つけます。