in bigtop-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/tez/TezSetup.java [42:87]
public static ShellResult configure(Params params) {
log.info("Configuring Tez");
TezParams tezParams = (TezParams) params;
String confDir = tezParams.confDir();
String serviceHome = tezParams.serviceHome();
String libDir = serviceHome + "/lib";
String hadoopUser = LocalSettings.users().get("hadoop");
String tezUser = tezParams.user();
String tezGroup = tezParams.group();
LinuxFileUtils.createDirectories(serviceHome, tezUser, tezGroup, Constants.PERMISSION_755, true);
LinuxFileUtils.createDirectories(confDir, tezUser, tezGroup, Constants.PERMISSION_755, true);
LinuxFileUtils.createDirectories(libDir, tezUser, tezGroup, Constants.PERMISSION_755, true);
List<PackageInfo> packages = params.packages();
for (PackageInfo packageInfo : packages) {
String source = tezParams.stackHome() + "/" + packageInfo.getName();
String dest = libDir + "/tez.tar.gz";
LinuxFileUtils.copyFile(source, dest);
LinuxFileUtils.updateOwner(dest, tezUser, tezGroup, false);
}
LinuxFileUtils.toFile(
ConfigType.XML,
MessageFormat.format("{0}/tez-site.xml", confDir),
tezUser,
tezGroup,
Constants.PERMISSION_644,
tezParams.tezSite(),
tezParams.getGlobalParamsMap());
LinuxFileUtils.toFileByTemplate(
tezParams.getTezEnvContent(),
MessageFormat.format("{0}/tez-env.sh", confDir),
tezUser,
tezGroup,
PERMISSION_755,
tezParams.getGlobalParamsMap());
// HdfsUtil.createDirectory(hadoopUser, "/apps");
// HdfsUtil.uploadFile(tezUser, tezParams.serviceHome() + "/lib/tez.tar.gz", "/apps/tez");
log.info("Successfully configured Tez");
return ShellResult.success();
}