| commit | a197d284c583be1a96134215d61fbfc2ec62b66c | [log] [tgz] |
|---|---|---|
| author | asagjj <shenyinjie@cmss.chinamobile.com> | Tue Apr 02 01:45:38 2019 +0800 |
| committer | avijayanhwx <14299376+avijayanhwx@users.noreply.github.com> | Mon Apr 01 10:45:38 2019 -0700 |
| tree | f586cef908476a3d98bc55933a9379d1a499c565 | |
| parent | 4ca5ffde8b1914eabaa57959b4184dd92fa9c9a1 [diff] |
AMBARI-25126.fix ambari-metric exception printed in namenode (#16) * AMBARI-25126.fix ambari-metric exception printed in namenode * Delete ambari-metrics.iml
diff --git a/ambari-metrics-common/src/main/java/org/apache/hadoop/metrics2/sink/timeline/availability/MetricSinkWriteShardHostnameHashingStrategy.java b/ambari-metrics-common/src/main/java/org/apache/hadoop/metrics2/sink/timeline/availability/MetricSinkWriteShardHostnameHashingStrategy.java index 25bff54..c79bbfb 100644 --- a/ambari-metrics-common/src/main/java/org/apache/hadoop/metrics2/sink/timeline/availability/MetricSinkWriteShardHostnameHashingStrategy.java +++ b/ambari-metrics-common/src/main/java/org/apache/hadoop/metrics2/sink/timeline/availability/MetricSinkWriteShardHostnameHashingStrategy.java
@@ -36,6 +36,10 @@ @Override public String findCollectorShard(List<String> collectorHosts) { + if(collectorHosts.size() ==0) { + LOG.warn("No metrics collectors alive, please check collector status!"); + return ""; + } long index = hostnameHash % collectorHosts.size(); index = index < 0 ? index + collectorHosts.size() : index; String collectorHost = collectorHosts.get((int) index);