You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ambari.apache.org by al...@apache.org on 2015/09/29 00:05:05 UTC
ambari git commit: 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)
Repository: ambari
Updated Branches:
refs/heads/trunk 460d191a1 -> 2b3401640
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/trunk
Commit: 2b3401640473c0b0988f52dff5683820107d3ecc
Parents: 460d191
Author: Alejandro Fernandez <af...@hortonworks.com>
Authored: Mon Sep 28 15:04:25 2015 -0700
Committer: Alejandro Fernandez <af...@hortonworks.com>
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))