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);