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/12/10 18:30:26 UTC
[3/6] storm git commit: close stream before returning;
close stream before returning;
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/7e270c24
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/7e270c24
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/7e270c24
Branch: refs/heads/master
Commit: 7e270c24f13423a909c413082602f22f6c9aeccf
Parents: 0e0cc9e
Author: Chuck Burgess <cb...@progressrail.com>
Authored: Wed Dec 9 15:48:13 2015 -0600
Committer: Chuck Burgess <cb...@progressrail.com>
Committed: Wed Dec 9 15:51:17 2015 -0600
----------------------------------------------------------------------
storm-core/src/jvm/backtype/storm/blobstore/BlobStore.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/7e270c24/storm-core/src/jvm/backtype/storm/blobstore/BlobStore.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/blobstore/BlobStore.java b/storm-core/src/jvm/backtype/storm/blobstore/BlobStore.java
index a714b76..2eba1d9 100644
--- a/storm-core/src/jvm/backtype/storm/blobstore/BlobStore.java
+++ b/storm-core/src/jvm/backtype/storm/blobstore/BlobStore.java
@@ -298,7 +298,9 @@ public abstract class BlobStore implements Shutdownable {
public byte[] readBlob(String key, Subject who) throws IOException, KeyNotFoundException, AuthorizationException {
ByteArrayOutputStream out = new ByteArrayOutputStream();
readBlobTo(key, out, who);
- return out.toByteArray();
+ byte[] bytes = out.toByteArray();
+ out.close();
+ return bytes;
}
/**