SAMZA-1023 ContainerProcessManager spams the job coordinator log with 'TaskManager...
authorBranislav Cogic <b.cogic@levi9.com>
Thu, 29 Sep 2016 13:56:24 +0000 (06:56 -0700)
committerJacob Maes <jmaes@linkedin.com>
Thu, 29 Sep 2016 13:56:24 +0000 (06:56 -0700)
samza-core/src/main/java/org/apache/samza/clustermanager/ContainerProcessManager.java

index 1fed2fb..b4309d9 100644 (file)
@@ -150,8 +150,8 @@ public class ContainerProcessManager implements ClusterResourceManager.Callback
   }
 
   public boolean shouldShutdown() {
-    log.info(" TaskManager state: Too many FailedContainers: {} No. Completed containers: {} Num Configured containers: {}" +
-      " AllocatorThread liveness: {} ", new Object[]{tooManyFailedContainers, state.completedContainers.get(), state.containerCount, allocatorThread.isAlive()});
+    log.debug(" TaskManager state: Completed containers: {}, Configured containers: {}, Is there too many FailedContainers: {}, Is AllocatorThread alive: {} "
+      , new Object[]{state.completedContainers.get(), state.containerCount, tooManyFailedContainers ? "yes" : "no", allocatorThread.isAlive() ? "yes" : "no"});
 
     if (exceptionOccurred != null) {
       log.error("Exception in ContainerProcessManager", exceptionOccurred);