storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kabh...@apache.org
Subject [1/3] storm git commit: initialize lastHeartbeatTimestamp before starting heartbeat task
Date Fri, 08 Jul 2016 07:22:37 GMT
Repository: storm
Updated Branches:
  refs/heads/master b96fef6c9 -> 1134d73ed


initialize lastHeartbeatTimestamp before starting heartbeat task


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/d38c4002
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/d38c4002
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/d38c4002

Branch: refs/heads/master
Commit: d38c40026ab5dac266986896424e6c25a440e512
Parents: d1280c2
Author: Slava Andreyev <sandreyev@ets.org>
Authored: Wed Jul 6 13:14:09 2016 -0400
Committer: Slava Andreyev <sandreyev@ets.org>
Committed: Wed Jul 6 13:14:09 2016 -0400

----------------------------------------------------------------------
 storm-core/src/jvm/org/apache/storm/task/ShellBolt.java | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/d38c4002/storm-core/src/jvm/org/apache/storm/task/ShellBolt.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/task/ShellBolt.java b/storm-core/src/jvm/org/apache/storm/task/ShellBolt.java
index 47b0763..1b3a0e5 100644
--- a/storm-core/src/jvm/org/apache/storm/task/ShellBolt.java
+++ b/storm-core/src/jvm/org/apache/storm/task/ShellBolt.java
@@ -138,11 +138,11 @@ public class ShellBolt implements IBolt {
         _writerThread = new Thread(new BoltWriterRunnable());
         _writerThread.start();
 
-        heartBeatExecutorService = MoreExecutors.getExitingScheduledExecutorService(new ScheduledThreadPoolExecutor(1));
-        heartBeatExecutorService.scheduleAtFixedRate(new BoltHeartbeatTimerTask(this), 1,
1, TimeUnit.SECONDS);
-
         LOG.info("Start checking heartbeat...");
         setHeartbeat();
+
+        heartBeatExecutorService = MoreExecutors.getExitingScheduledExecutorService(new ScheduledThreadPoolExecutor(1));
+        heartBeatExecutorService.scheduleAtFixedRate(new BoltHeartbeatTimerTask(this), 1,
1, TimeUnit.SECONDS);
     }
 
     public void execute(Tuple input) {


Mime
View raw message