You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2014/07/25 23:36:41 UTC
[2/4] git commit: added retrying infos to the messages on
inconsistent assignments.
added retrying infos to the messages on inconsistent assignments.
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/cfda011f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/cfda011f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/cfda011f
Branch: refs/heads/master
Commit: cfda011f936d9bc23870e9b0687d3d55941f1ab0
Parents: 14bcc9b
Author: iwasakims <iw...@example.com>
Authored: Wed Jul 23 06:53:18 2014 -0700
Committer: iwasakims <iw...@example.com>
Committed: Wed Jul 23 06:53:18 2014 -0700
----------------------------------------------------------------------
storm-core/src/clj/backtype/storm/daemon/supervisor.clj | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/cfda011f/storm-core/src/clj/backtype/storm/daemon/supervisor.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/backtype/storm/daemon/supervisor.clj b/storm-core/src/clj/backtype/storm/daemon/supervisor.clj
index 8d1ac46..ec96c10 100644
--- a/storm-core/src/clj/backtype/storm/daemon/supervisor.clj
+++ b/storm-core/src/clj/backtype/storm/daemon/supervisor.clj
@@ -78,7 +78,7 @@
assignments)
(catch RuntimeException e
(if (> @retries 2) (throw e) (swap! retries inc))
- (log-warn (.getMessage e))
+ (log-warn (.getMessage e) ": retrying " @retries " of 3")
existing-assignment))))
(defn- read-storm-code-locations