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"));