Merge pull request mattbaird#246 from maraino/master

Send an unread Buffer to the ErrorChannel
vrabeux · Nov 30, 2015 · bc78e4c · bc78e4c
2 parents 6a1bd9c + e9e5019
commit bc78e4c
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/lib/corebulk.go b/lib/corebulk.go
@@ -193,6 +193,7 @@ func (b *BulkIndexer) startHttpSender() {
 				//  2.  Retry then return error and let runner decide
 				//  3.  Retry, then log to disk?   retry later?
 				if err != nil {
+					buf = bytes.NewBuffer(bufCopy.Bytes())
 					if b.RetryForSeconds > 0 {
 						time.Sleep(time.Second * time.Duration(b.RetryForSeconds))
 						err = b.Sender(bufCopy)