this fixed a memory leak, but caused bulk indexing to fail. reverting…

… for now.
mattbaird · Jun 18, 2014 · 0c98885 · 0c98885
1 parent 736b7e4
commit 0c98885
Showing 1 changed file with 2 additions and 1 deletion.
diff --git 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
 }