我试图重现mapreduce设计模式手册中的bloom过滤示例。
在下面，我将只显示感兴趣的代码：

public static class BloomFilteringMapper extends Mapper<Object, Text, Text, NullWritable>
{
    private BloomFilter filter = new BloomFilter();

    protected void setup( Context context ) throws IOException
    {
        URI[] files = DistributedCache.getCacheFiles( context.getConfiguration() );
        String path = files[0].getPath();
        System.out.println( "Reading Bloom Filter from: " + path );
        DataInputStream strm = new DataInputStream( new FileInputStream( path ) );
        filter.readFields( strm );
        strm.close();
    }
    //...
}
public static void main( String[] args ) throws Exception
{
    Job job = new Job( new Configuration(), "description" );
    URI uri = new URI("hdfs://localhost:9000/user/draxent/comment.bloomfilter");
    DistributedCache.addCacheFile( uri, job.getConfiguration() );
    //...
}

当我尝试执行它时，我收到以下错误：
java.io.filenotfoundexception:/user/draxent/comment.bloomfilter
但是执行命令：

bin/hadoop fs -ls

我可以看到文件：

-rw-r--r--   1 draxent supergroup        405 2015-11-25 17:12 /user/draxent/comment.bloomfilter

所以我确信问题就在眼前：

URI uri = new URI("hdfs://localhost:9000/user/draxent/comment.bloomfilter");

但我尝试了几种不同的配置，比如：
"hdfs://user/draxent/comment.bloomfilter"
“/user/draxent/comment.bloomfilter”
“注解.过滤器”
没有人工作。
我试着查看cfeduke的实现，但是我没能解决我的问题。
回答意见：
ravindra:uri文件[0]包含在main中传递的字符串元素；
曼朱纳斯：是的，你说得对。但由于文件存在（您可以从bin/hadoop fs-ls中看到），这意味着传递给fileinputstream的字符串路径存在问题。但我会像往常一样把绳子传给它。我查过了，路径值是：comment.bloomfilter。。。所以它必须是对的。