的MapReduce分布式缓存

我使用的MapReduce分布式缓存

 Configuration cng=new Configuration(); 
    JobConf conf = new JobConf(cng, Driver.class); 
    DistributedCache.addCacheFile(new Path("DCache/Orders.txt").toUri(), cng);

其中数据缓存/ Orders.txt是HDFS文件添加一个文件的Hadoop分布式缓存。

当我尝试使用，以从缓存中检索该文件中映射的配置方法：

Path[] cacheFiles=DistributedCache.getLocalCacheFiles(conf);

我得到空指针。什么可能是错误？

谢谢

来源

2010-07-02 user381928

我知道porblem是由于路径。如何在addCacheFile中指定路径或URI？是绝对路径吗？如果我想以URI的形式表示，我应该如何写它？ – user381928 2010-07-02 10:34:20

我在Windows上使用单节点群集。 – user381928 2010-07-02 10:52:48

DistributedCache不能在单节点模式下工作，它只是返回一个空指针。或者至少这是我对当前版本的经验。

我认为url应该以hdfs标识符开头。

http://hadoop.apache.org/common/docs/current/mapred_tutorial.html#DistributedCache

来源

2010-08-04 00:19:23 akintayo

应该不在，所以/ user /文件夹/文件而不是hdfs：// user/folder/file – akintayo 2010-08-04 18:07:18

的MapReduce分布式缓存

回答

相关问题