You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ambari.apache.org by jo...@apache.org on 2015/03/18 21:26:22 UTC
ambari git commit: AMBARI-10126 - Alert Scheduler Is Double
Scheduling Jobs (jonathanhurley)
Repository: ambari
Updated Branches:
refs/heads/trunk 32e121563 -> 68468feee
AMBARI-10126 - Alert Scheduler Is Double Scheduling Jobs (jonathanhurley)
Project: http://git-wip-us.apache.org/repos/asf/ambari/repo
Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/68468fee
Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/68468fee
Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/68468fee
Branch: refs/heads/trunk
Commit: 68468feeeeb35ca9edd4899ea8b1abafb7c2742a
Parents: 32e1215
Author: Jonathan Hurley <jh...@hortonworks.com>
Authored: Wed Mar 18 16:08:20 2015 -0400
Committer: Jonathan Hurley <jh...@hortonworks.com>
Committed: Wed Mar 18 16:26:14 2015 -0400
----------------------------------------------------------------------
ambari-agent/src/main/python/ambari_agent/Controller.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ambari/blob/68468fee/ambari-agent/src/main/python/ambari_agent/Controller.py
----------------------------------------------------------------------
diff --git a/ambari-agent/src/main/python/ambari_agent/Controller.py b/ambari-agent/src/main/python/ambari_agent/Controller.py
index eeca4c2..bb85337 100644
--- a/ambari-agent/src/main/python/ambari_agent/Controller.py
+++ b/ambari-agent/src/main/python/ambari_agent/Controller.py
@@ -99,6 +99,8 @@ class Controller(threading.Thread):
stacks_cache_dir, common_services_cache_dir, host_scripts_cache_dir,
self.cluster_configuration, config)
+ self.alert_scheduler_handler.start()
+
def __del__(self):
logger.info("Server connection disconnected.")
@@ -347,8 +349,6 @@ class Controller(threading.Thread):
message = registerResponse['response']
logger.info("Registration response from %s was %s", self.serverHostname, message)
- self.alert_scheduler_handler.start()
-
if self.isRegistered:
# Clearing command queue to stop executing "stale" commands
# after registration