diff --git a/storm-server/src/main/java/org/apache/storm/daemon/supervisor/timer/ReportWorkerHeartbeats.java b/storm-server/src/main/java/org/apache/storm/daemon/supervisor/timer/ReportWorkerHeartbeats.java
index 75d54becb0b..3a250732f88 100644
--- a/storm-server/src/main/java/org/apache/storm/daemon/supervisor/timer/ReportWorkerHeartbeats.java
+++ b/storm-server/src/main/java/org/apache/storm/daemon/supervisor/timer/ReportWorkerHeartbeats.java
@@ -50,13 +50,8 @@ public void run() {
 
     private SupervisorWorkerHeartbeats getAndResetWorkerHeartbeats() {
         Map<String, LSWorkerHeartbeat> localHeartbeats;
-        try {
-            localHeartbeats = SupervisorUtils.readWorkerHeartbeats(this.conf);
-            return getSupervisorWorkerHeartbeatsFromLocal(localHeartbeats);
-        } catch (Exception e) {
-            LOG.error("Read local worker heartbeats error, skipping heartbeats for this round, msg:{}", e.getMessage());
-            return null;
-        }
+        localHeartbeats = SupervisorUtils.readWorkerHeartbeats(this.conf);
+        return getSupervisorWorkerHeartbeatsFromLocal(localHeartbeats);
     }
 
     private SupervisorWorkerHeartbeats getSupervisorWorkerHeartbeatsFromLocal(Map<String, LSWorkerHeartbeat> localHeartbeats) {