hadoop 1.2.1 是多少位编译的
发布网友
发布时间:2022-04-29 15:48
我来回答
共2个回答
热心网友
时间:2022-05-07 02:45
至于该存放目录的分配是通过调用rpc访问jobtracker的方法来进行分配的,下面看一下jobtracker的分配代码:
final
path
stagingrootdir
=
new
path(conf.get(
"maprece.jobtracker.staging.root.dir",
"/tmp/hadoop/mapred/staging"));
final
filesystem
fs
=
stagingrootdir.getfilesystem(conf);
return
fs.makequalified(new
path(stagingrootdir,
user
+
"/.staging")).tostring();
注意上面代码所生成的stagingrootdir是所有job文件的存放目录,是一个根目录,并不单指当前job。