Repository: storm Updated Branches: refs/heads/1.1.x-branch 9c4e34aa7 -> c859d95e8
STORM-2500: remove call to waitUntilReady Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/c82c849e Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/c82c849e Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/c82c849e Branch: refs/heads/1.1.x-branch Commit: c82c849efadba5ef4219950bd9c8a3015ae6d34b Parents: 181d71e Author: Zachary.smith <[email protected]> Authored: Wed Aug 16 12:21:11 2017 -0400 Committer: Zachary.smith <[email protected]> Committed: Wed Aug 16 12:21:11 2017 -0400 ---------------------------------------------------------------------- .../storm/pacemaker/pacemaker_state_factory.clj | 15 +++++++-------- 1 file changed, 7 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/c82c849e/storm-core/src/clj/org/apache/storm/pacemaker/pacemaker_state_factory.clj ---------------------------------------------------------------------- diff --git a/storm-core/src/clj/org/apache/storm/pacemaker/pacemaker_state_factory.clj b/storm-core/src/clj/org/apache/storm/pacemaker/pacemaker_state_factory.clj index 3889dcf..cb364d1 100644 --- a/storm-core/src/clj/org/apache/storm/pacemaker/pacemaker_state_factory.clj +++ b/storm-core/src/clj/org/apache/storm/pacemaker/pacemaker_state_factory.clj @@ -106,14 +106,13 @@ (defn get-pacemaker-write-client [conf servers client-pool] ;; Client should be created in case of an exception or first write call ;; Shutdown happens in the retry loop - (try - (.waitUntilReady - (let [client (get @client-pool (first @servers))] - (if (nil? client) - (do - (swap! client-pool merge {(first @servers) (PacemakerClient. conf (first @servers))}) - (get @client-pool (first @servers))) - client))) + (try + (let [client (get @client-pool (first @servers))] + (if (nil? client) + (do + (swap! client-pool merge {(first @servers) (PacemakerClient. conf (first @servers))}) + (get @client-pool (first @servers))) + client)) (catch Exception e (throw e))))
