Repository: ambari Updated Branches: refs/heads/branch-2.4 9d9bbe7df -> 96de8ef01 refs/heads/trunk 075eb17d0 -> 49fcedd73
AMBARI-17447. Datanode start fails with umask 027 on ambari-server node (aonishuk) Project: http://git-wip-us.apache.org/repos/asf/ambari/repo Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/49fcedd7 Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/49fcedd7 Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/49fcedd7 Branch: refs/heads/trunk Commit: 49fcedd73cd368d2045b66cb0f0a2437f4ed01e8 Parents: 075eb17 Author: Andrew Onishuk <aonis...@hortonworks.com> Authored: Mon Jun 27 15:45:19 2016 +0300 Committer: Andrew Onishuk <aonis...@hortonworks.com> Committed: Mon Jun 27 15:45:19 2016 +0300 ---------------------------------------------------------------------- .../src/main/python/ambari_server/serverSetup.py | 14 +++++++++++--- 1 file changed, 11 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ambari/blob/49fcedd7/ambari-server/src/main/python/ambari_server/serverSetup.py ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/python/ambari_server/serverSetup.py b/ambari-server/src/main/python/ambari_server/serverSetup.py index dad3083..d80c25a 100644 --- a/ambari-server/src/main/python/ambari_server/serverSetup.py +++ b/ambari-server/src/main/python/ambari_server/serverSetup.py @@ -786,9 +786,14 @@ class JDKSetupLinux(JDKSetup): def adjust_jce_permissions(self, jdk_path): ambari_user = read_ambari_user() - cmd = self.SET_JCE_PERMISSIONS.format(ambari_user, jdk_path, configDefaults.JDK_SECURITY_DIR) - cmd += " && " + self.SET_JCE_FILE_MODE.format(jdk_path, configDefaults.JDK_SECURITY_DIR, "*") - cmd += " && " + self.SET_JCE_JAR_MODE.format(jdk_path, configDefaults.JDK_SECURITY_DIR, "*.jar") + cmds = [] + if ambari_user: + cmds.append(self.SET_JCE_PERMISSIONS.format(ambari_user, jdk_path, configDefaults.JDK_SECURITY_DIR)) + cmds.append(self.SET_JCE_FILE_MODE.format(jdk_path, configDefaults.JDK_SECURITY_DIR, "*")) + cmds.append(self.SET_JCE_JAR_MODE.format(jdk_path, configDefaults.JDK_SECURITY_DIR, "*.jar")) + + cmd = " && ".join(cmds) + process = subprocess.Popen(cmd, stdout=subprocess.PIPE, stdin=subprocess.PIPE, @@ -797,6 +802,9 @@ class JDKSetupLinux(JDKSetup): ) (stdoutdata, stderrdata) = process.communicate() + if process.returncode != 0: + print_warning_msg("Failed to change jce permissions. {0}\n{1}".format(stderrdata, stdoutdata)) + def download_and_install_jdk(options): properties = get_ambari_properties() if properties == -1:
