Repository: storm Updated Branches: refs/heads/master 10b33a61b -> 3600953b6
Pass delete-node-blobstore through to zk-state Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/812cc1ec Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/812cc1ec Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/812cc1ec Branch: refs/heads/master Commit: 812cc1ec1e99509523aa27a1d064fd14e28d4391 Parents: 79a2a2a Author: Ilya Ostrovskiy <[email protected]> Authored: Sat Dec 5 10:29:36 2015 -0500 Committer: Ilya Ostrovskiy <[email protected]> Committed: Mon Dec 7 08:39:56 2015 -0500 ---------------------------------------------------------------------- .../src/clj/org/apache/storm/pacemaker/pacemaker_state_factory.clj | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/812cc1ec/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 537397a..d99442b 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 @@ -53,6 +53,7 @@ (create_sequential [this path data acls] (.create_sequential zk-state path data acls)) (set_data [this path data acls] (.set_data zk-state path data acls)) (delete_node [this path] (.delete_node zk-state path)) + (delete_node_blobstore [this path nimbus-host-port-info] (.delete_node_blobstore zk-state path nimbus-host-port-info)) (get_data [this path watch?] (.get_data zk-state path watch?)) (get_data_with_version [this path watch?] (.get_data_with_version zk-state path watch?)) (get_version [this path watch?] (.get_version zk-state path watch?))
