You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ambari.apache.org by wu...@apache.org on 2022/10/21 16:40:05 UTC
[ambari-metrics] branch master updated: AMBARI-25301: Ambari metrics HA does not work for Hbase/any /services (#45)
This is an automated email from the ASF dual-hosted git repository.
wuzhiguo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ambari-metrics.git
The following commit(s) were added to refs/heads/master by this push:
new 82880b3 AMBARI-25301: Ambari metrics HA does not work for Hbase/any /services (#45)
82880b3 is described below
commit 82880b3031a38d3c3a298610615ad61bac216ca3
Author: glorious06 <lu...@gmail.com>
AuthorDate: Fri Oct 21 18:40:00 2022 +0200
AMBARI-25301: Ambari metrics HA does not work for Hbase/any /services (#45)
---
.../hadoop/metrics2/sink/timeline/HadoopTimelineMetricsSink.java | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
diff --git a/ambari-metrics-hadoop-sink/src/main/java/org/apache/hadoop/metrics2/sink/timeline/HadoopTimelineMetricsSink.java b/ambari-metrics-hadoop-sink/src/main/java/org/apache/hadoop/metrics2/sink/timeline/HadoopTimelineMetricsSink.java
index 1a4a5fd..0a38bdd 100644
--- a/ambari-metrics-hadoop-sink/src/main/java/org/apache/hadoop/metrics2/sink/timeline/HadoopTimelineMetricsSink.java
+++ b/ambari-metrics-hadoop-sink/src/main/java/org/apache/hadoop/metrics2/sink/timeline/HadoopTimelineMetricsSink.java
@@ -108,7 +108,12 @@ public class HadoopTimelineMetricsSink extends AbstractTimelineMetricsSink imple
// Load collector configs
protocol = conf.getString(COLLECTOR_PROTOCOL, "http");
- collectorHosts = parseHostsStringArrayIntoCollection(conf.getStringArray(COLLECTOR_HOSTS_PROPERTY));
+ String collectorHostStr = conf.getString(COLLECTOR_HOSTS_PROPERTY);
+ String[] collectorHostArr = null;
+ if(collectorHostStr !=null) {
+ collectorHostArr = collectorHostStr.split(",");
+ }
+ collectorHosts = parseHostsStringArrayIntoCollection(collectorHostArr);
port = conf.getString(COLLECTOR_PORT, "6188");
hostInMemoryAggregationEnabled = conf.getBoolean(HOST_IN_MEMORY_AGGREGATION_ENABLED_PROPERTY, false);
hostInMemoryAggregationPort = conf.getInt(HOST_IN_MEMORY_AGGREGATION_PORT_PROPERTY, 61888);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@ambari.apache.org
For additional commands, e-mail: commits-help@ambari.apache.org