AMBARI-13233. Error message for ambari agent install failure when the ping port is taken by old agent process should state port and old process (Di Li via alejandro)
Project: http://git-wip-us.apache.org/repos/asf/ambari/repo Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/2b340164 Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/2b340164 Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/2b340164 Branch: refs/heads/branch-dev-patch-upgrade Commit: 2b3401640473c0b0988f52dff5683820107d3ecc Parents: 460d191 Author: Alejandro Fernandez <[email protected]> Authored: Mon Sep 28 15:04:25 2015 -0700 Committer: Alejandro Fernandez <[email protected]> Committed: Mon Sep 28 15:04:25 2015 -0700 ---------------------------------------------------------------------- ambari-agent/src/main/python/ambari_agent/PingPortListener.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ambari/blob/2b340164/ambari-agent/src/main/python/ambari_agent/PingPortListener.py ---------------------------------------------------------------------- diff --git a/ambari-agent/src/main/python/ambari_agent/PingPortListener.py b/ambari-agent/src/main/python/ambari_agent/PingPortListener.py index 46be26b..313c060 100644 --- a/ambari-agent/src/main/python/ambari_agent/PingPortListener.py +++ b/ambari-agent/src/main/python/ambari_agent/PingPortListener.py @@ -39,7 +39,7 @@ class PingPortListener(threading.Thread): self.host = '0.0.0.0' self.port = int(self.config.get('agent','ping_port')) if not self.port == None and not self.port == 0: - (stdoutdata, stderrdata) = self.run_os_command_in_shell(FUSER_CMD.format(str(self.port), "{print $2}")) + (stdoutdata, stderrdata) = self.run_os_command_in_shell(FUSER_CMD.format(str(self.port), "{print $1}")) if stdoutdata.strip() and stdoutdata.strip().isdigit(): (stdoutdata, stderrdata) = self.run_os_command_in_shell(PSPF_CMD.format(stdoutdata.strip())) raise Exception(PORT_IN_USE_MESSAGE.format(str(self.port), stdoutdata))
