From 7a52ce7e59570da58d60947770becbf6081b7243 Mon Sep 17 00:00:00 2001 From: Hao Chen Date: Wed, 22 Feb 2017 21:57:11 +0800 Subject: [PATCH] [MINOR] Support source_host aside host in metric collector --- eagle-external/hadoop_jmx_collector/metric_collector.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/eagle-external/hadoop_jmx_collector/metric_collector.py b/eagle-external/hadoop_jmx_collector/metric_collector.py index a472bbe907..2176db2491 100644 --- a/eagle-external/hadoop_jmx_collector/metric_collector.py +++ b/eagle-external/hadoop_jmx_collector/metric_collector.py @@ -433,6 +433,8 @@ def register(self, *listeners): def jmx_reader(self, source): host = source["host"] + if source.has_key("source_host"): + host=source["source_host"] port=source["port"] https=source["https"] protocol = "https" if https else "http" @@ -562,4 +564,4 @@ def filter_metric(self, metric): for name_filter in self.metric_name_filter: if fnmatch.fnmatch(metric["metric"], name_filter): return True - return False \ No newline at end of file + return False