Github user danny0405 commented on a diff in the pull request:
https://github.com/apache/storm/pull/2319#discussion_r138781061
--- Diff: storm-core/src/clj/org/apache/storm/cluster.clj ---
@@ -244,15 +255,19 @@
;; Watches should be used for optimization. When ZK is reconnecting,
they're not guaranteed to be called.
(defnk mk-storm-cluster-state
- [cluster-state-spec :acls nil :context (ClusterStateContext.)]
- (let [[solo? cluster-state] (if (instance? ClusterState
cluster-state-spec)
- [false cluster-state-spec]
- [true (mk-distributed-cluster-state
cluster-state-spec :auth-conf cluster-state-spec :acls acls :context context)])
+ [conf :cluster-state nil :acls nil :context (ClusterStateContext.)
:backend nil]
+ (let [[solo? cluster-state] (if (and (not-nil? cluster-state) (instance?
ClusterState cluster-state))
+ [false cluster-state]
+ [true (mk-distributed-cluster-state conf
:auth-conf conf :acls acls :context context)])
+ assignments-backend (if (nil? backend)
+ (doto (InMemoryAssignmentBackend.) (.prepare
nil nil))
--- End diff --
okey, i will make it configurable
---
