From 5fe6ac938c1ff82e80ee3eba5626f458c4dc18e5 Mon Sep 17 00:00:00 2001 From: "Robert (Bobby) Evans" Date: Thu, 7 Aug 2014 15:11:41 -0500 Subject: [PATCH] Added in the sorting suggested as a part of STORM-341 --- storm-core/src/clj/backtype/storm/daemon/nimbus.clj | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/storm-core/src/clj/backtype/storm/daemon/nimbus.clj b/storm-core/src/clj/backtype/storm/daemon/nimbus.clj index bf22a1bcc5c..72ce9dd7779 100644 --- a/storm-core/src/clj/backtype/storm/daemon/nimbus.clj +++ b/storm-core/src/clj/backtype/storm/daemon/nimbus.clj @@ -608,7 +608,9 @@ new-topology->executor->node+port)) (defn changed-executors [executor->node+port new-executor->node+port] - (let [slot-assigned (reverse-map executor->node+port) + (let [executor->node+port (if executor->node+port (sort executor->node+port) nil) + new-executor->node+port (if new-executor->node+port (sort new-executor->node+port) nil) + slot-assigned (reverse-map executor->node+port) new-slot-assigned (reverse-map new-executor->node+port) brand-new-slots (map-diff slot-assigned new-slot-assigned)] (apply concat (vals brand-new-slots))