DistributedCache.Version #的作用

姬俊驰
2023-12-01

http://blog.sina.com.cn/s/blog_7800d921010174eg.html


1.

DistributedCache.createSymlink(conf);
DistributedCache.addCacheFile(new URI(“file.txt#test”), conf);

一定要放在job的初始化前面,否则会在mapper或者reducer中出现文件找不到的情况

2.

file.txt#test

#后面的test相当于是一个链接(别名),这时候可以在maper或者reducer中直接用FileReader(“test”)读取文件


 类似资料: