为什么DistributedCache破坏我的文件名

Question

我有一个奇怪的问题，DistributedCache似乎更改我的文件的名称，它使用原始名称作为父文件夹并将该文件添加为子项。

即文件夹\ FILENAME.EXT变成文件夹\ FILENAME.EXT \ FILENAME.EXT

任何想法，我的代码如下。 感谢 Akintayo

String paramsLocation="/user/fwang/settings/ecgparams.txt"; 
DistributedCache.addCacheFile(new URI(paramsLocation), firstStageConf); 

Path[] paths = DistributedCache.getLocalCacheFiles(job); 
for (Path path: paths) { 
    if (path.getName().equals(ecgParamsFilename)) { 
    File f = new File(path.toString()); 
    if (f.exists()) { 
    ecgParamsFullFileName = f.getAbsolutePath(); 
    //this becomes /user/fwang/settings/ecgparams.txt/ecgparams.txt 
    } 
    } 
} 

更新：2010年8月16日 更换用下面的原始呼叫，停止名的截断。

DistributedCache.addCacheArchive(new URI(ecgParamsLocation), firstStageConf); 

Answer 1

你确定要使用addCacheArchive()？还有一个addCacheFile()http://hadoop.apache.org/common/docs/r0.15.2/api/org/apache/hadoop/filecache/DistributedCache.html#getCacheFiles%28org.apache.hadoop.conf.Configuration%29。