You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2015/08/05 22:46:46 UTC
[2/3] storm git commit: STORM-913: modify zookeeper.clj fix EOF
exception
STORM-913: modify zookeeper.clj fix EOF exception
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/0d79febc
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/0d79febc
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/0d79febc
Branch: refs/heads/master
Commit: 0d79febc05f02603ac8be0512ff791b53b896905
Parents: fa370b5
Author: caofangkun <ca...@gmail.com>
Authored: Fri Jul 3 15:36:45 2015 +0800
Committer: caofangkun <ca...@gmail.com>
Committed: Fri Jul 3 15:36:45 2015 +0800
----------------------------------------------------------------------
storm-core/src/clj/backtype/storm/zookeeper.clj | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/0d79febc/storm-core/src/clj/backtype/storm/zookeeper.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/backtype/storm/zookeeper.clj b/storm-core/src/clj/backtype/storm/zookeeper.clj
index 390b20b..f38abcc 100644
--- a/storm-core/src/clj/backtype/storm/zookeeper.clj
+++ b/storm-core/src/clj/backtype/storm/zookeeper.clj
@@ -108,7 +108,8 @@
(when (exists-node? zk path false)
(try-cause (.. zk (delete) (deletingChildrenIfNeeded) (forPath (normalize-path path)))
(catch KeeperException$NoNodeException e
- ;; do nothing)
+ ;; do nothing
+ )
(catch Exception e (throw (wrap-in-runtime e)))))))
(defn mkdirs