Skip to content

Commit 458b9f2

Browse files
author
Nathan Marz
committed
improve variable name
1 parent 35275c1 commit 458b9f2

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/clj/backtype/storm/scheduler/IsolationScheduler.clj

+3-3
Original file line numberDiff line numberDiff line change
@@ -192,17 +192,17 @@
192192
(.blacklistHost cluster host))
193193
)))
194194

195-
(let [non-iso-topologies (->> topology-worker-specs
195+
(let [failed-iso-topologies (->> topology-worker-specs
196196
(mapcat (fn [[top-id worker-specs]]
197197
(if-not (empty? worker-specs) [top-id])
198198
)))]
199-
(if (empty? non-iso-topologies)
199+
(if (empty? failed-iso-topologies)
200200
;; run default scheduler on non-isolated topologies
201201
(-<> topology-worker-specs
202202
allocated-topologies
203203
(leftover-topologies topologies <>)
204204
(DefaultScheduler/default-schedule <> cluster))
205-
(log-warn "Unstable to isolate topologies " (pr-str non-iso-topologies) ". Will wait for enough resources for isolated topologies before allocating any other resources.")
205+
(log-warn "Unstable to isolate topologies " (pr-str failed-iso-topologies) ". Will wait for enough resources for isolated topologies before allocating any other resources.")
206206
))
207207
(.setBlacklistedHosts cluster orig-blacklist)
208208
))

0 commit comments

Comments
 (0)