apache · huijunwu · Oct 29, 2019 · Oct 28, 2019
diff --git 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();
-            }
-          });
-        }
       }
     });
   }