Repository: ambari Updated Branches: refs/heads/branch-2.4 c7d6f520a -> 28622c00e
Revert "AMBARI-17190. Ignore logs for performance testing of grok patters (Hayat Behlim via oleewere)" This reverts commit c7d6f520a799b6083a5cb6521601622117f61596. Project: http://git-wip-us.apache.org/repos/asf/ambari/repo Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/28622c00 Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/28622c00 Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/28622c00 Branch: refs/heads/branch-2.4 Commit: 28622c00e75d0cc4b4a712146f503cf35a323a77 Parents: c7d6f52 Author: oleewere <oleew...@gmail.com> Authored: Wed Jun 15 19:46:28 2016 +0200 Committer: oleewere <oleew...@gmail.com> Committed: Wed Jun 15 19:46:28 2016 +0200 ---------------------------------------------------------------------- .../ambari/logfeeder/logconfig/FetchConfigFromSolr.java | 7 ++----- .../main/java/org/apache/ambari/logfeeder/util/SolrUtil.java | 7 ++----- 2 files changed, 4 insertions(+), 10 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ambari/blob/28622c00/ambari-logsearch/ambari-logsearch-logfeeder/src/main/java/org/apache/ambari/logfeeder/logconfig/FetchConfigFromSolr.java ---------------------------------------------------------------------- diff --git a/ambari-logsearch/ambari-logsearch-logfeeder/src/main/java/org/apache/ambari/logfeeder/logconfig/FetchConfigFromSolr.java b/ambari-logsearch/ambari-logsearch-logfeeder/src/main/java/org/apache/ambari/logfeeder/logconfig/FetchConfigFromSolr.java index f2d074a..1f86dd0 100644 --- a/ambari-logsearch/ambari-logsearch-logfeeder/src/main/java/org/apache/ambari/logfeeder/logconfig/FetchConfigFromSolr.java +++ b/ambari-logsearch/ambari-logsearch-logfeeder/src/main/java/org/apache/ambari/logfeeder/logconfig/FetchConfigFromSolr.java @@ -48,11 +48,8 @@ public class FetchConfigFromSolr extends Thread { @Override public void run() { String zkHosts = LogFeederUtil.getStringProperty("logfeeder.solr.zkhosts"); - String solrUrl = LogFeederUtil.getStringProperty("logfeeder.solr.url"); - if ((zkHosts == null || zkHosts.trim().length() == 0) - && (solrUrl == null || solrUrl.trim().length() == 0)) { - logger - .warn("Solr ZKHosts or solrUrl for UserConfig/History is not set. Won't look for level configuration from Solr."); + if( zkHosts == null || zkHosts.trim().length() == 0 ) { + logger.warn("Solr ZKHosts for UserConfig/History is not set. Won't look for level configuration from Solr."); return; } solrConfigInterval = LogFeederUtil.getIntProperty("logfeeder.solr.config.interval", solrConfigInterval); http://git-wip-us.apache.org/repos/asf/ambari/blob/28622c00/ambari-logsearch/ambari-logsearch-logfeeder/src/main/java/org/apache/ambari/logfeeder/util/SolrUtil.java ---------------------------------------------------------------------- diff --git a/ambari-logsearch/ambari-logsearch-logfeeder/src/main/java/org/apache/ambari/logfeeder/util/SolrUtil.java b/ambari-logsearch/ambari-logsearch-logfeeder/src/main/java/org/apache/ambari/logfeeder/util/SolrUtil.java index 29feef7..200a603 100644 --- a/ambari-logsearch/ambari-logsearch-logfeeder/src/main/java/org/apache/ambari/logfeeder/util/SolrUtil.java +++ b/ambari-logsearch/ambari-logsearch-logfeeder/src/main/java/org/apache/ambari/logfeeder/util/SolrUtil.java @@ -143,7 +143,7 @@ public class SolrUtil { + solrDetail + ", response=" + response); break; } else { - logger.warn("Solr is not reachable yet. getCollections() attempt count=" + pingCount + logger.warn("Solr is not not reachable yet. getCollections() attempt count=" + pingCount + ". Will sleep for " + waitIntervalMS + " ms and try again." + " solr=" + solrDetail + ", response=" + response); @@ -194,10 +194,7 @@ public class SolrUtil { } } } catch (Exception e) { - final String logMessageKey = this.getClass().getSimpleName() - + "_FETCH_FILTER_CONFIG_ERROR"; - LogFeederUtil.logErrorMessageByInterval(logMessageKey, - "Error getting filter config from solr", e, logger, Level.ERROR); + logger.error("Error getting config", e); } return configMap; }
