You should not use DistrubutedCache. It is deprecated.
See this:
http://stackoverflow.com/questions/21239722/hadoop-distributedcache-is-deprecated-what-is-the-preferred-api
Regards,
Shahab
On Mon, Dec 22, 2014 at 6:22 AM, Marko Dinic
wrote:
> Thanks a lot, it works!
>
> Do you have any ideas w
Thanks a lot, it works!
Do you have any ideas what was the problem? Should this work in fully
distributed mode, or I need to make some modifications? When to use
DistributedCache.addCacheFile and when
DIstributedCache.addLocalCacheFile?
Thanks again!
On Mon 22 Dec 2014 11:03:36 AM CET, unme
Driver
Configuration conf = new Configuration();
FileSystem fs = FileSystem.get(conf);
Path cachefile = new Path("path/to/file");
FileStatus[] list = fs.globStatus(cachefile);
for (FileStatus status : list) {
DistributedCache.addCacheFile(status.getPath().toUri(), conf);
}
In setup
public void
Hello Hadoopers,
I'm getting this exception in Hadoop while trying to read file that was
added to distributed cache, and the strange thing is that the file
exists on the given location
java.io.FileNotFoundException: File does not exist:
/tmp/hadoop-pera/mapred/local/taskTracker/distcache
