diff --git a/lib/database/elasticsearch_adapter.js b/lib/database/elasticsearch_adapter.js index f06702b..68d117e 100644 --- a/lib/database/elasticsearch_adapter.js +++ b/lib/database/elasticsearch_adapter.js @@ -391,7 +391,7 @@ ElasticSearchDB.prototype.updateObjects = function(patches, callback) { 'def parsed = jsonSlurper.parseText(\''+JSON.stringify(dbObjects[id])+'\');'+ 'ctx._source = parsed;'; - bulk.push({update: {_type: objectModel, _id: id}}); + bulk.push({update: {_type: objectModel, _id: id, _retry_on_conflict: 10}}); bulk.push({script: script}); c(); }, function() {