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:27 GMT
Repository: storm
Updated Branches:
  refs/heads/1.0.x-branch 1beb76188 -> 5ef9534e5


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/dae20521
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/dae20521
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/dae20521

Branch: refs/heads/1.0.x-branch
Commit: dae20521489abba2aac3a7e33186c787fcdfd815
Parents: 1beb761
Author: Slava Andreyev <sandreyev@ets.org>
Authored: Wed Jul 6 13:14:09 2016 -0400
Committer: Jungtaek Lim <kabhwan@gmail.com>
Committed: Fri Jul 8 16:21:39 2016 +0900

----------------------------------------------------------------------
 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/dae20521/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