From 4dcf2190861fa6a64af6133bd6e5215d58654af8 Mon Sep 17 00:00:00 2001 From: kimchy Date: Wed, 21 Jul 2010 23:45:15 +0300 Subject: [PATCH] after raising a failure, return, don't try and write the blob --- .../blobstore/support/ImmutableAppendableBlobContainer.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/common/blobstore/support/ImmutableAppendableBlobContainer.java b/modules/elasticsearch/src/main/java/org/elasticsearch/common/blobstore/support/ImmutableAppendableBlobContainer.java index 0f9698e9ba9..e540b8c3318 100644 --- a/modules/elasticsearch/src/main/java/org/elasticsearch/common/blobstore/support/ImmutableAppendableBlobContainer.java +++ b/modules/elasticsearch/src/main/java/org/elasticsearch/common/blobstore/support/ImmutableAppendableBlobContainer.java @@ -53,8 +53,9 @@ public class ImmutableAppendableBlobContainer extends AbstractBlobContainer impl String partBlobName = blobName + ".a" + (part++); try { listener.withStream(out); - } catch (IOException e) { + } catch (Exception e) { listener.onFailure(e); + return; } FastByteArrayInputStream is = new FastByteArrayInputStream(out.unsafeByteArray(), 0, out.size()); container.writeBlob(partBlobName, is, out.size(), new ImmutableBlobContainer.WriterListener() {