You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ambari.apache.org by sw...@apache.org on 2013/05/02 22:35:33 UTC
svn commit: r1478516 - in /incubator/ambari/trunk: CHANGES.txt
ambari-server/src/main/java/org/apache/ambari/server/agent/HeartbeatMonitor.java
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));