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: STORM-2279: Unable to open bolt page of storm ui
Date Tue, 10 Jan 2017 00:54:48 GMT
Repository: storm
Updated Branches:
  refs/heads/1.0.x-branch 3b0837ee4 -> 4b44b40ea


STORM-2279: Unable to open bolt page of storm ui


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

Branch: refs/heads/1.0.x-branch
Commit: 5f3fe962973822ebcdc5829b652ccffbc4185492
Parents: ce0b155
Author: Raghav Kumar Gautam <raghav@apache.org>
Authored: Mon Jan 9 11:17:05 2017 -0800
Committer: Raghav Kumar Gautam <raghav@apache.org>
Committed: Mon Jan 9 11:17:05 2017 -0800

----------------------------------------------------------------------
 storm-core/src/clj/org/apache/storm/daemon/nimbus.clj | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/5f3fe962/storm-core/src/clj/org/apache/storm/daemon/nimbus.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/org/apache/storm/daemon/nimbus.clj b/storm-core/src/clj/org/apache/storm/daemon/nimbus.clj
index daccb83..b7f9d19 100644
--- a/storm-core/src/clj/org/apache/storm/daemon/nimbus.clj
+++ b/storm-core/src/clj/org/apache/storm/daemon/nimbus.clj
@@ -2141,8 +2141,11 @@
               (let [eventlogger-tasks (sort (get component->tasks
                                                  EVENTLOGGER-COMPONENT-ID))
                     ;; Find the task the events from this component route to.
-                    task-index (mod (TupleUtils/listHashCode [component-id])
-                                    (count eventlogger-tasks))
+                    task-index (mod
+                                (+ (mod (TupleUtils/listHashCode [component-id])
+                                        (count eventlogger-tasks))
+                                   (count eventlogger-tasks))
+                                (count eventlogger-tasks))
                     task-id (nth eventlogger-tasks task-index)
                     eventlogger-exec (first (filter (fn [[start stop]]
                                                       (between? task-id start stop))


Mime
View raw message