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
 }