AMBARI-2120. Add few logs to allow root-cause the issue where agent seems to unable to communicate with the server. (smohanty)

git-svn-id: https://svn.apache.org/repos/asf/incubator/ambari/trunk@1482120 13f79535-47bb-0310-9956-ffa450edef68

CHANGES.txt

@@ -842,6 +842,9 @@ Trunk (unreleased changes):
 
  BUG FIXES
 
+ AMBARI-2120. Add few logs to allow root-cause the issue where agent seems
+ to unable to communicate with the server. (smohanty)
+
  AMBARI-2116. Add parameters to improve HIVE performance. (swagle)
 
  AMBARI-2117. Set jobtracker retire interval. (swagle)

ambari-agent/src/main/python/ambari_agent/security.py

@@ -81,7 +81,7 @@ class CachedHTTPSConnection:
         self.httpsconn = VerifiedHTTPSConnection(self.server, self.port)
         self.httpsconn.connect()
         self.connected = True
-      # possible exceptions are catched and processed in Controller
+      # possible exceptions are caught and processed in Controller
 
   
   def forceClear(self):
@@ -96,9 +96,10 @@ class CachedHTTPSConnection:
       response = self.httpsconn.getresponse()
       readResponse = response.read()
     except Exception as ex:
-      # This exception is catched later in Controller
+      # This exception is caught later in Controller
       logger.debug("Error in sending/receving data from the server " +
                    traceback.format_exc())
+      logger.info("Encountered communication error. Details: " + repr(ex))
       self.connected = False
       raise IOError("Error occured during connecting to the server: " + str(ex))
     return readResponse

ambari-server/src/main/java/org/apache/ambari/server/agent/HeartBeatHandler.java

@@ -105,12 +105,10 @@ public class HeartBeatHandler {
       return createRegisterCommand();
     }
 
-    if (LOG.isDebugEnabled()) {
-      LOG.debug("Received heartbeat from host"
-          + ", hostname=" + hostname
-          + ", currentResponseId=" + currentResponseId
-          + ", receivedResponseId=" + heartbeat.getResponseId());
-    }
+    LOG.info("Received heartbeat from host"
+        + ", hostname=" + hostname
+        + ", currentResponseId=" + currentResponseId
+        + ", receivedResponseId=" + heartbeat.getResponseId());
 
     if (heartbeat.getResponseId() == currentResponseId - 1) {
       LOG.warn("Old responseId received - response was lost - returning cached response");

ambari-server/src/main/java/org/apache/ambari/server/agent/rest/AgentResource.java

@@ -106,7 +106,10 @@ public class AgentResource {
     HeartBeatResponse heartBeatResponse;
     try {
       heartBeatResponse = hh.handleHeartBeat(message);
-      LOG.debug("Sending heartbeat response " + heartBeatResponse);
+      LOG.info("Sending heartbeat response with response id " + heartBeatResponse.getResponseId());
+      if (LOG.isDebugEnabled()) {
+        LOG.debug("Response details " + heartBeatResponse);
+      }
     } catch (Exception e) {
       LOG.info("Error in HeartBeat", e);
       throw new WebApplicationException(500);