This is an automated email from the ASF dual-hosted git repository.

dmitriusan pushed a commit to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/ambari.git


The following commit(s) were added to refs/heads/branch-2.7 by this push:
     new 8ddc968  AMBARI-25565. ConfigHelper.java logging consumes most server 
logs for clusters with many hosts. (dvitiuk) (#3238)
8ddc968 is described below

commit 8ddc968f56a96c72449e4f704fa6f1460b4cdce2
Author: dvitiiuk <[email protected]>
AuthorDate: Wed Oct 7 18:26:52 2020 +0300

    AMBARI-25565. ConfigHelper.java logging consumes most server logs for 
clusters with many hosts. (dvitiuk) (#3238)
    
    Co-authored-by: Dmytro Vitiuk <[email protected]>
---
 .../java/org/apache/ambari/server/state/ConfigHelper.java  | 14 +++++++++-----
 1 file changed, 9 insertions(+), 5 deletions(-)

diff --git 
a/ambari-server/src/main/java/org/apache/ambari/server/state/ConfigHelper.java 
b/ambari-server/src/main/java/org/apache/ambari/server/state/ConfigHelper.java
index c685c79..e7df496 100644
--- 
a/ambari-server/src/main/java/org/apache/ambari/server/state/ConfigHelper.java
+++ 
b/ambari-server/src/main/java/org/apache/ambari/server/state/ConfigHelper.java
@@ -2044,16 +2044,20 @@ public class ConfigHelper {
       }
       Map<String, Map<String, String>> configurations = new HashMap<>();
       Map<String, Map<String, Map<String, String>>> configurationAttributes = 
new HashMap<>();
-      if (LOG.isInfoEnabled()) {
-        LOG.info("For configs update on host {} will be used cluster entity 
{}", hostId, cl.getClusterEntity().toString());
+      if (LOG.isDebugEnabled()) {
+        LOG.debug("For configs update on host {} will be used cluster entity 
{}", hostId, cl.getClusterEntity().toString());
       }
       Map<String, DesiredConfig> clusterDesiredConfigs = 
cl.getDesiredConfigs(false);
-      LOG.info("For configs update on host {} will be used following cluster 
desired configs {}", hostId,
-          clusterDesiredConfigs.toString());
+      if (LOG.isDebugEnabled()) {
+        LOG.debug("For configs update on host {} will be used following 
cluster desired configs {}", hostId,
+            clusterDesiredConfigs.toString());
+      }
 
       Map<String, Map<String, String>> configTags =
           getEffectiveDesiredTags(cl, host.getHostName(), 
clusterDesiredConfigs);
-      LOG.info("For configs update on host {} will be used following effective 
desired tags {}", hostId, configTags.toString());
+      if (LOG.isDebugEnabled()) {
+        LOG.debug("For configs update on host {} will be used following 
effective desired tags {}", hostId, configTags.toString());
+      }
 
       getAndMergeHostConfigs(configurations, configTags, cl);
       configurations = unescapeConfigNames(configurations);

Reply via email to