svn commit: r1478516 - in /incubator/ambari/trunk: CHANGES.txt ambari-server/src/main/java/org/apache/ambari/server/agent/HeartbeatMonitor.java

[swagle]

Author: swagle
Date: Thu May  2 20:35:33 2013
New Revision: 1478516

URL: http://svn.apache.org/r1478516
Log:
AMBARI-1979. Last HeartBeat time and heartbeat status for agent take around 2-3 
minutes to update on a server restart.. (swagle)

Modified:
    incubator/ambari/trunk/CHANGES.txt
    
incubator/ambari/trunk/ambari-server/src/main/java/org/apache/ambari/server/agent/HeartbeatMonitor.java

Modified: incubator/ambari/trunk/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/incubator/ambari/trunk/CHANGES.txt?rev=1478516&r1=1478515&r2=1478516&view=diff
==============================================================================
--- incubator/ambari/trunk/CHANGES.txt (original)
+++ incubator/ambari/trunk/CHANGES.txt Thu May  2 20:35:33 2013
@@ -825,6 +825,9 @@ Trunk (unreleased changes):
 
  BUG FIXES
 
+ AMBARI-1979. Last HeartBeat time and heartbeat status for agent take around 
2-3 
+ minutes to update on a server restart. (swagle)
+
  AMBARI-1983. Add new parameters to improve HBase MTTR. HDPLocal fixes. 
  (swagle)
 

Modified: 
incubator/ambari/trunk/ambari-server/src/main/java/org/apache/ambari/server/agent/HeartbeatMonitor.java
URL: 
http://svn.apache.org/viewvc/incubator/ambari/trunk/ambari-server/src/main/java/org/apache/ambari/server/agent/HeartbeatMonitor.java?rev=1478516&r1=1478515&r2=1478516&view=diff
==============================================================================
--- 
incubator/ambari/trunk/ambari-server/src/main/java/org/apache/ambari/server/agent/HeartbeatMonitor.java
 (original)
+++ 
incubator/ambari/trunk/ambari-server/src/main/java/org/apache/ambari/server/agent/HeartbeatMonitor.java
 Thu May  2 20:35:33 2013
@@ -119,7 +119,7 @@ public class HeartbeatMonitor implements
       } catch (AmbariException e) {
         LOG.warn("Exception in getting host object; Is it fatal?", e);
       }
-      if (lastHeartbeat + 5*threadWakeupInterval < now) {
+      if (lastHeartbeat + 2*threadWakeupInterval < now) {
         LOG.warn("Hearbeat lost from host "+host);
         //Heartbeat is expired
         hostObj.handleEvent(new HostHeartbeatLostEvent(host));