ambari-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From oleew...@apache.org
Subject ambari git commit: Revert "AMBARI-17190. Ignore logs for performance testing of grok patters (Hayat Behlim via oleewere)"
Date Wed, 15 Jun 2016 17:47:00 GMT
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 <oleewere@gmail.com>
Authored: Wed Jun 15 19:46:28 2016 +0200
Committer: oleewere <oleewere@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;
   }


Mime
View raw message