i using distributedcache. there no files in cache after execution of code. have referred other similar questions answers not solve issue.
please find code below:
configuration conf = new configuration(); job job1 = new job(conf, "distributed cache"); configuration conf1 = job1.getconfiguration(); distributedcache.addcachefile(new path("file").touri(), conf1); system.out.println("distributed cache file "+distributedcache.getlocalcachefiles(conf1)); this gives null..
the same thing when given inside mapper gives null hence. please let me know suggestions.
thanks
try getcachefiles() instead of getlocalcachefiles()
Comments
Post a Comment