Skip to content

Commit a4d79ae

Browse files
committed
Correctly display bulk error from elastic search
When an error occur message is: - Error: [object Object] Now it’s the real message: - Error: Field [_id] is defined twice in [mytype]
1 parent 33986c1 commit a4d79ae

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

lib/writable-bulk.js

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,10 @@ WritableBulk.prototype._flushBulk = function(callback) {
8282
var bulkItemResp = resp.items[i];
8383
var key = Object.keys(bulkItemResp)[0];
8484
if (bulkItemResp[key].error) {
85-
self.emit('error', new Error(bulkItemResp[key].error));
85+
var err = new Error(bulkItemResp[key].error.reason || bulkItemResp[key].error);
86+
err.reason = bulkItemResp[key].error.reason;
87+
err.type = bulkItemResp[key].error.type;
88+
self.emit('error', err);
8689
}
8790
}
8891
}

0 commit comments

Comments
 (0)