storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject [2/4] storm git commit: Addressing review comments
Date Wed, 15 Jul 2015 20:01:53 GMT
Addressing review comments


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

Branch: refs/heads/master
Commit: 1b3e9edfc6597f19cee8b73310c30c0c92739eda
Parents: 2d03041
Author: rfarivar <rfarivar@yahoo-inc.com>
Authored: Tue Jul 14 14:38:47 2015 -0500
Committer: rfarivar <rfarivar@yahoo-inc.com>
Committed: Tue Jul 14 14:38:47 2015 -0500

----------------------------------------------------------------------
 .../storm/utils/StormBoundedExponentialBackoffRetry.java         | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/1b3e9edf/storm-core/src/jvm/backtype/storm/utils/StormBoundedExponentialBackoffRetry.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/utils/StormBoundedExponentialBackoffRetry.java
b/storm-core/src/jvm/backtype/storm/utils/StormBoundedExponentialBackoffRetry.java
index afb7e2c..5422c2e 100644
--- a/storm-core/src/jvm/backtype/storm/utils/StormBoundedExponentialBackoffRetry.java
+++ b/storm-core/src/jvm/backtype/storm/utils/StormBoundedExponentialBackoffRetry.java
@@ -44,8 +44,8 @@ public class StormBoundedExponentialBackoffRetry extends BoundedExponentialBacko
         expRetriesThreshold = 1;
         while ((1 << (expRetriesThreshold + 1)) < ((maxSleepTimeMs - baseSleepTimeMs)
/ 2))
             expRetriesThreshold++;
-        LOG.debug("The baseSleepTimeMs [" + baseSleepTimeMs + "] the maxSleepTimeMs [" +
maxSleepTimeMs + "] " +
-                "the maxRetries [" + maxRetries + "]");
+        LOG.debug("The baseSleepTimeMs [{}] the maxSleepTimeMs [{}] the maxRetries [{}]",

+				baseSleepTimeMs, maxSleepTimeMs, maxRetries);
         if (baseSleepTimeMs > maxSleepTimeMs) {
             LOG.warn("Misconfiguration: the baseSleepTimeMs [" + baseSleepTimeMs + "] can't
be greater than " +
                     "the maxSleepTimeMs [" + maxSleepTimeMs + "].");


Mime
View raw message