       (advance-cluster-time cluster 11)
       (bind slot-executors2 (slot-assignments cluster storm-id))
       (bind executor->start2 (executor-start-times cluster storm-id))
-      (check-distribution slot-executors2 [2 2 2 3])
+      (check-executor-distribution slot-executors2 [2 2 2 3])
       (check-consistency cluster "test")
 
       (bind common (first (find-first (fn [[k v]] (= 3 (count v))) slot-executors2)))

  (let [state (:storm-cluster-state cluster)
        assignment (.assignment-info state storm-id nil)]
    (keys (:executor->node+port assignment))
    ))

(defnk check-consistency [cluster storm-name :assigned? true]

      (submit-local-topology (:nimbus cluster) "test" {TOPOLOGY-WORKERS 4} topology)  ; distribution should be 2, 2, 2, 3 ideally
      (bind storm-id (get-storm-id state "test"))
      (bind slot-executors (slot-assignments cluster storm-id))
      (check-executor-distribution slot-executors [9])
      (check-consistency cluster "test")

      (add-supervisor cluster :ports 2)
      (advance-cluster-time cluster 11)
      (bind slot-executors (slot-assignments cluster storm-id))
      (bind executor->start (executor-start-times cluster storm-id))
      (check-executor-distribution slot-executors [3 3 3])
      (check-consistency cluster "test")

      (add-supervisor cluster :ports 8)
