effective log using slf4j feature ({})

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

Branch: refs/heads/0.9.3-branch
Commit: 4095078b44d7b6d2c177be65c0758b3194f5ce43
Parents: 1a0d4bd
Author: Jungtaek Lim <[email protected]>
Authored: Sat Oct 11 21:43:05 2014 +0900
Committer: Jungtaek Lim <[email protected]>
Committed: Sat Oct 11 21:43:05 2014 +0900

----------------------------------------------------------------------
 storm-core/src/jvm/backtype/storm/spout/ShellSpout.java | 4 ++--
 storm-core/src/jvm/backtype/storm/task/ShellBolt.java   | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/4095078b/storm-core/src/jvm/backtype/storm/spout/ShellSpout.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/spout/ShellSpout.java 
b/storm-core/src/jvm/backtype/storm/spout/ShellSpout.java
index fc2ddf2..6cc6196 100644
--- a/storm-core/src/jvm/backtype/storm/spout/ShellSpout.java
+++ b/storm-core/src/jvm/backtype/storm/spout/ShellSpout.java
@@ -244,8 +244,8 @@ public class ShellSpout implements ISpout {
             long currentTimeMillis = System.currentTimeMillis();
             long lastHeartbeat = getLastHeartbeat();
 
-            LOG.debug("current time : " + currentTimeMillis + ", last 
heartbeat : " + lastHeartbeat
-                    + ", worker timeout (ms) : " + workerTimeoutMills);
+            LOG.debug("current time : {}, last heartbeat : {}, worker timeout 
(ms) : ",
+                    currentTimeMillis, lastHeartbeat, workerTimeoutMills);
 
             if (currentTimeMillis - lastHeartbeat > workerTimeoutMills) {
                 spout.die(new RuntimeException("subprocess heartbeat 
timeout"));

http://git-wip-us.apache.org/repos/asf/storm/blob/4095078b/storm-core/src/jvm/backtype/storm/task/ShellBolt.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/task/ShellBolt.java 
b/storm-core/src/jvm/backtype/storm/task/ShellBolt.java
index cb70649..0d9d706 100644
--- a/storm-core/src/jvm/backtype/storm/task/ShellBolt.java
+++ b/storm-core/src/jvm/backtype/storm/task/ShellBolt.java
@@ -299,8 +299,8 @@ public class ShellBolt implements IBolt {
             long currentTimeMillis = System.currentTimeMillis();
             long lastHeartbeat = getLastHeartbeat();
 
-            LOG.debug("BOLT - current time : " + currentTimeMillis + ", last 
heartbeat : " + lastHeartbeat
-                    + ", worker timeout (ms) : " + workerTimeoutMills);
+            LOG.debug("BOLT - current time : {}, last heartbeat : {}, worker 
timeout (ms) : ",
+                    currentTimeMillis, lastHeartbeat, workerTimeoutMills);
 
             if (currentTimeMillis - lastHeartbeat > workerTimeoutMills) {
                 bolt.die(new RuntimeException("subprocess heartbeat timeout"));

Reply via email to