You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ambari.apache.org by ol...@apache.org on 2016/09/28 09:42:19 UTC

[52/52] [abbrv] ambari git commit: AMBARI-18246. Logfeeder cleanup - appendum for branch-2.5 (oleewere)

AMBARI-18246. Logfeeder cleanup - appendum for branch-2.5 (oleewere)

Change-Id: Ie7b8a669ecd418ca566b5d060d5f0a40ee84824f


Project: http://git-wip-us.apache.org/repos/asf/ambari/repo
Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/63dcb184
Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/63dcb184
Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/63dcb184

Branch: refs/heads/logsearch-ga
Commit: 63dcb184c6db48511d2ebb86e060439830a2e74d
Parents: 44644cd
Author: oleewere <ol...@gmail.com>
Authored: Wed Sep 28 11:38:30 2016 +0200
Committer: oleewere <ol...@gmail.com>
Committed: Wed Sep 28 11:38:30 2016 +0200

----------------------------------------------------------------------
 .../apache/ambari/logfeeder/metrics/MetricsManager.java | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ambari/blob/63dcb184/ambari-logsearch/ambari-logsearch-logfeeder/src/main/java/org/apache/ambari/logfeeder/metrics/MetricsManager.java
----------------------------------------------------------------------
diff --git a/ambari-logsearch/ambari-logsearch-logfeeder/src/main/java/org/apache/ambari/logfeeder/metrics/MetricsManager.java b/ambari-logsearch/ambari-logsearch-logfeeder/src/main/java/org/apache/ambari/logfeeder/metrics/MetricsManager.java
index a679a33..fca2b20 100644
--- a/ambari-logsearch/ambari-logsearch-logfeeder/src/main/java/org/apache/ambari/logfeeder/metrics/MetricsManager.java
+++ b/ambari-logsearch/ambari-logsearch-logfeeder/src/main/java/org/apache/ambari/logfeeder/metrics/MetricsManager.java
@@ -49,14 +49,14 @@ public class MetricsManager {
     LOG.info("Initializing MetricsManager()");
     amsClient = new LogFeederAMSClient();
 
-    if (amsClient.getCollectorUri(null) != null) {
+    if (amsClient.getCollectorUri() != null) {
       findNodeHostName();
       if (nodeHostName == null) {
         isMetricsEnabled = false;
         LOG.error("Failed getting hostname for node. Disabling publishing LogFeeder metrics");
       } else {
         isMetricsEnabled = true;
-        LOG.info("LogFeeder Metrics is enabled. Metrics host=" + amsClient.getCollectorUri(null));
+        LOG.info("LogFeeder Metrics is enabled. Metrics host=" + amsClient.getCollectorUri());
       }
     } else {
       LOG.info("LogFeeder Metrics publish is disabled");
@@ -80,14 +80,14 @@ public class MetricsManager {
       }
       if (nodeHostName == null) {
         isMetricsEnabled = false;
-        logger.error("Failed getting hostname for node. Disabling publishing LogFeeder metrics");
+        LOG.error("Failed getting hostname for node. Disabling publishing LogFeeder metrics");
       } else {
         isMetricsEnabled = true;
-        logger.info("LogFeeder Metrics is enabled. Metrics host="
-          + amsClient.getCollectorUri(null));
+        LOG.info("LogFeeder Metrics is enabled. Metrics host="
+          + amsClient.getCollectorUri());
       }
     } else {
-      logger.info("LogFeeder Metrics publish is disabled");
+      LOG.info("LogFeeder Metrics publish is disabled");
     }
   }