Repository: ambari Updated Branches: refs/heads/trunk e9270ab75 -> c1789e255
AMBARI-17149 : HadoopTimelineMetricsSink from AMS prevents HBase RS process shutdown (avijayan) Project: http://git-wip-us.apache.org/repos/asf/ambari/repo Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/c1789e25 Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/c1789e25 Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/c1789e25 Branch: refs/heads/trunk Commit: c1789e2553862463d8864912f64afad71f9d792a Parents: e9270ab Author: Aravindan Vijayan <[email protected]> Authored: Fri Jun 10 09:46:30 2016 -0700 Committer: Aravindan Vijayan <[email protected]> Committed: Fri Jun 10 09:46:30 2016 -0700 ---------------------------------------------------------------------- .../metrics2/sink/timeline/HadoopTimelineMetricsSink.java | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ambari/blob/c1789e25/ambari-metrics/ambari-metrics-hadoop-sink/src/main/java/org/apache/hadoop/metrics2/sink/timeline/HadoopTimelineMetricsSink.java ---------------------------------------------------------------------- diff --git a/ambari-metrics/ambari-metrics-hadoop-sink/src/main/java/org/apache/hadoop/metrics2/sink/timeline/HadoopTimelineMetricsSink.java b/ambari-metrics/ambari-metrics-hadoop-sink/src/main/java/org/apache/hadoop/metrics2/sink/timeline/HadoopTimelineMetricsSink.java index ff44169..c534121 100644 --- a/ambari-metrics/ambari-metrics-hadoop-sink/src/main/java/org/apache/hadoop/metrics2/sink/timeline/HadoopTimelineMetricsSink.java +++ b/ambari-metrics/ambari-metrics-hadoop-sink/src/main/java/org/apache/hadoop/metrics2/sink/timeline/HadoopTimelineMetricsSink.java @@ -42,6 +42,7 @@ import java.util.Map; import java.util.Set; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; +import java.util.concurrent.ThreadFactory; @InterfaceAudience.Public @InterfaceStability.Evolving @@ -63,8 +64,14 @@ public class HadoopTimelineMetricsSink extends AbstractTimelineMetricsSink imple private SubsetConfiguration conf; // Cache the rpc port used and the suffix to use if the port tag is found private Map<String, String> rpcPortSuffixes = new HashMap<>(10); - private final ExecutorService executorService = Executors.newSingleThreadExecutor(); + private final ExecutorService executorService = Executors.newSingleThreadExecutor(new ThreadFactory() { + public Thread newThread(Runnable r) { + Thread t = Executors.defaultThreadFactory().newThread(r); + t.setDaemon(true); + return t; + } + }); @Override public void init(SubsetConfiguration conf) { @@ -437,5 +444,6 @@ public class HadoopTimelineMetricsSink extends AbstractTimelineMetricsSink imple } } }); + executorService.shutdown(); } }
