From fac9d3aee2284531e32867d624b8fe9b5d416646 Mon Sep 17 00:00:00 2001 From: Huijun Wu Date: Mon, 28 Oct 2019 16:11:44 -0700 Subject: [PATCH] makemetricstriggerperiodic --- .../apache/heron/healthmgr/HealthManagerMetrics.java | 11 +---------- 1 file changed, 1 insertion(+), 10 deletions(-) diff --git a/heron/healthmgr/src/java/org/apache/heron/healthmgr/HealthManagerMetrics.java b/heron/healthmgr/src/java/org/apache/heron/healthmgr/HealthManagerMetrics.java index 4f22cd17ddc..5920833605e 100644 --- a/heron/healthmgr/src/java/org/apache/heron/healthmgr/HealthManagerMetrics.java +++ b/heron/healthmgr/src/java/org/apache/heron/healthmgr/HealthManagerMetrics.java @@ -102,19 +102,10 @@ public HealthManagerMetrics(int metricsMgrPort) throws IOException { int interval = (int) systemConfig.getHeronMetricsExportInterval().getSeconds(); - looper.registerTimerEvent(Duration.ofSeconds(interval), new Runnable() { + looper.registerPeriodicEvent(Duration.ofSeconds(interval), new Runnable() { @Override public void run() { sendMetrics(); - // next timer task - if (looper != null) { - looper.registerTimerEvent(Duration.ofSeconds(interval), new Runnable() { - @Override - public void run() { - sendMetrics(); - } - }); - } } }); }