diff --git a/src/main/java/org/elasticsearch/common/blobstore/fs/FsBlobContainer.java b/src/main/java/org/elasticsearch/common/blobstore/fs/FsBlobContainer.java index bd66ad3b564..912dd712e70 100644 --- a/src/main/java/org/elasticsearch/common/blobstore/fs/FsBlobContainer.java +++ b/src/main/java/org/elasticsearch/common/blobstore/fs/FsBlobContainer.java @@ -89,6 +89,10 @@ public class FsBlobContainer extends AbstractBlobContainer { public OutputStream createOutput(String blobName) throws IOException { final File file = new File(path, blobName); return new BufferedOutputStream(new FilterOutputStream(new FileOutputStream(file)) { + + @Override // FilterOutputStream#write(byte[] b, int off, int len) is trappy writes every single byte + public void write(byte[] b, int off, int len) throws IOException { out.write(b, off, len);} + @Override public void close() throws IOException { super.close();