hadoop - Flume シンク ファイルの Hadoop ストリーミング MapReduce - FileNotFoundException

Question

次の例外が発生しています：

java.io.FileNotFoundException: File does not exist: /log1/20131025/2013102509_at1.1382659200021.tmp
    at org.apache.hadoop.hdfs.DFSClient$DFSInputStream.fetchLocatedBlocks(DFSClient.java:2006)
    at org.apache.hadoop.hdfs.DFSClient$DFSInputStream.openInfo(DFSClient.java:1975)
...

MR ジョブの実行中。Flume はファイル名を からxxx.tmpに変更xxx. し、MR タスクはファイルを見つけることができず (MR は を読み込もうとしていますxxx.tmp)、エラーをスローします。

FileNotFoundException を回避する方法がわかりません。

Hadoop ストリーミング経由で MR ジョブを実行しています ( $hadoop jar contrib/streaming/hadoop-streaming-1.2.1.jar...)

xxx.tmp ファイルを除外するオプションはありますか?