@@ -170,7 +170,7 @@ func (e *Elastic) BulkSave(index string, obj []map[string]interface{}) {
id := util.ObjToString(v["_id"])
delete(v, "_id")
util.Debug(id, v)
- req = req.Add(es.NewBulkIndexRequest().Index(index).Id(id).Doc(v))
+ req = req.Add(es.NewBulkIndexRequest().Index(index).Type("_doc").Id(id).Doc(v))
}
_, err := req.Do(context.Background())
if err != nil {
