소스 검색

AMBARI-3701. Reduce logs emitted to report heartbeats from agents (Dmytro Shkvyra via dsen)

Dmitry Sen 11 년 전
부모
커밋
d6176141a9

+ 2 - 2
ambari-server/conf/unix/log4j.properties

@@ -23,8 +23,8 @@ log4j.rootLogger=INFO,file
 # Direct log messages to a log file
 log4j.appender.file=org.apache.log4j.RollingFileAppender
 log4j.appender.file.File=/var/log/ambari-server/ambari-server.log
-log4j.appender.file.MaxFileSize=10MB
-log4j.appender.file.MaxBackupIndex=20
+log4j.appender.file.MaxFileSize=80MB
+log4j.appender.file.MaxBackupIndex=60
 log4j.appender.file.layout=org.apache.log4j.PatternLayout
 log4j.appender.file.layout.ConversionPattern=%d{ABSOLUTE} %5p [%t] %c{1}:%L - %m%n
 

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

@@ -120,7 +120,7 @@ public class HeartBeatHandler {
       return createRegisterCommand();
     }
 
-    LOG.info("Received heartbeat from host"
+    LOG.debug("Received heartbeat from host"
         + ", hostname=" + hostname
         + ", currentResponseId=" + currentResponseId
         + ", receivedResponseId=" + heartbeat.getResponseId());
@@ -200,7 +200,7 @@ public class HeartBeatHandler {
         throw new AmbariException("Invalid command report, service: " + service);
       }
       if (actionMetadata.getActions(service.toLowerCase()).contains(report.getRole())) {
-        LOG.info(report.getRole() + " is an action - skip component lookup");
+        LOG.debug(report.getRole() + " is an action - skip component lookup");
       } else {
         try {
           Service svc = cl.getService(service);

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

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