From 0c98885a2b2575c99882263dfc4bf6aae9079a63 Mon Sep 17 00:00:00 2001 From: Matthew Baird Date: Wed, 18 Jun 2014 15:47:01 -0700 Subject: [PATCH] this fixed a memory leak, but caused bulk indexing to fail. reverting for now. --- core/bulk.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/core/bulk.go b/core/bulk.go index a5e72fe6..eace3425 100644 --- a/core/bulk.go +++ b/core/bulk.go @@ -294,7 +294,8 @@ func (b *BulkIndexer) startDocChannel() { func (b *BulkIndexer) send(buf *bytes.Buffer) { //b2 := *b.buf b.sendBuf <- buf - b.buf.Reset() + b.buf = new(bytes.Buffer) + // b.buf.Reset() b.docCt = 0 }