Merge pull request #11 from LF-Engineering/add-common-util

Enhance elastic bulk errors

Author: code-sleuth

elastic/client.go

@@ -195,6 +195,7 @@ func (p *ClientProvider) Bulk(body []byte) ([]byte, error) {
 
 	res, err := req.Do(context.Background(), p.client)
 	if err != nil {
+		log.Printf("ReqErr: %s", err.Error())
 		return nil, err
 	}
 	defer func() {
@@ -212,6 +213,10 @@ func (p *ClientProvider) Bulk(body []byte) ([]byte, error) {
 		return resBytes, nil
 	}
 
+	if res.StatusCode == 413 {
+		return nil, errors.New("payload too large. decrease documents to <= 1000")
+	}
+
 	if res.IsError() {
 
 		var e map[string]interface{}