1
J'ajoute un fichier à cache distribué Hadoop à l'aideMapReduce cache distribué
Configuration cng=new Configuration();
JobConf conf = new JobConf(cng, Driver.class);
DistributedCache.addCacheFile(new Path("DCache/Orders.txt").toUri(), cng);
où DCache/Orders.txt est le fichier HDFS.
Lorsque je tente de récupérer ce fichier à partir du cache dans la méthode de configuration de mappeur en utilisant:
Path[] cacheFiles=DistributedCache.getLocalCacheFiles(conf);
je reçois pointeur NULL. Quelle peut être l'erreur?
Merci
Je sais que le porblem est dû à la voie. Comment le chemin ou l'URI doit-il être spécifié dans le fichier addCacheFile ?? Est-ce le chemin absolu. Si je veux représenter sous la forme d'URI, comment dois-je l'écrire? – user381928
J'utilise un cluster à nœud unique sur Windows. – user381928