You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ambari.apache.org by ao...@apache.org on 2018/06/07 13:05:26 UTC
[ambari] 02/02: AMBARI-24049. Ambari-agent should report when
message is received (aonishuk)
This is an automated email from the ASF dual-hosted git repository.
aonishuk pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/ambari.git
commit d743faf5f1233dac1cf596058f4e054bb4444d47
Author: Andrew Onishuk <ao...@hortonworks.com>
AuthorDate: Thu Jun 7 11:53:54 2018 +0300
AMBARI-24049. Ambari-agent should report when message is received (aonishuk)
---
ambari-agent/src/main/python/ambari_agent/HeartbeatThread.py | 2 --
1 file changed, 2 deletions(-)
diff --git a/ambari-agent/src/main/python/ambari_agent/HeartbeatThread.py b/ambari-agent/src/main/python/ambari_agent/HeartbeatThread.py
index 49e0ce5..3403bb2 100644
--- a/ambari-agent/src/main/python/ambari_agent/HeartbeatThread.py
+++ b/ambari-agent/src/main/python/ambari_agent/HeartbeatThread.py
@@ -125,7 +125,6 @@ class HeartbeatThread(threading.Thread):
logger.info("Sending registration request")
logger.debug("Registration request is {0}".format(registration_request))
- self.server_responses_listener.connection = self.connection
response = self.blocking_request(registration_request, Constants.REGISTRATION_ENDPOINT)
logger.info("Registration response received")
@@ -134,7 +133,6 @@ class HeartbeatThread(threading.Thread):
self.handle_registration_response(response)
for endpoint, cache, listener, subscribe_to in self.post_registration_requests:
- listener.connection = self.connection
# should not hang forever on these requests
response = self.blocking_request({'hash': cache.hash}, endpoint, log_handler=listener.get_log_message)
try:
--
To stop receiving notification emails like this one, please contact
aonishuk@apache.org.