You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by kn...@apache.org on 2015/12/17 22:09:21 UTC
[2/6] storm git commit: removing close method as shutdown does that
removing close method as shutdown does that
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/c511a7e5
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/c511a7e5
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/c511a7e5
Branch: refs/heads/master
Commit: c511a7e5581c2aff5c4ddd25c5507950fea08005
Parents: f27e5bc
Author: Sanket <sc...@untilservice-lm>
Authored: Tue Dec 8 17:12:02 2015 -0600
Committer: Sanket <sc...@untilservice-lm>
Committed: Tue Dec 8 17:12:02 2015 -0600
----------------------------------------------------------------------
storm-core/src/jvm/backtype/storm/blobstore/LocalFsBlobStore.java | 1 -
1 file changed, 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/c511a7e5/storm-core/src/jvm/backtype/storm/blobstore/LocalFsBlobStore.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/blobstore/LocalFsBlobStore.java b/storm-core/src/jvm/backtype/storm/blobstore/LocalFsBlobStore.java
index 77845b0..7f075a1 100644
--- a/storm-core/src/jvm/backtype/storm/blobstore/LocalFsBlobStore.java
+++ b/storm-core/src/jvm/backtype/storm/blobstore/LocalFsBlobStore.java
@@ -268,7 +268,6 @@ public class LocalFsBlobStore extends BlobStore {
SettableBlobMeta meta = getStoredBlobMeta(key);
_aclHandler.hasPermissions(meta.get_acl(), READ, who, key);
if (zkClient.checkExists().forPath(BLOBSTORE_SUBTREE + key) == null) {
- zkClient.close();
return 0;
}
replicationCount = zkClient.getChildren().forPath(BLOBSTORE_SUBTREE + key).size();