• A+

es UpdateByQuery 出现 VersionConflictEngineException

问题出在多次更新统一doc出现版本不一致,抛出异常,修改不成功。
解决方法:
确认你的操作不会造成数据不一致的情况下,
UpdateByQueryRequestBuilder实现类增加执行方法abortOnVersionConflict(false)

like this

UpdateByQueryRequestBuilder ubqrb = UpdateByQueryAction.INSTANCE.newRequestBuilder(client);
Script script = new Script(scriptStr);
BulkIndexByScrollResponse scrollResponse = ubqrb.source(index).script(script)
.filter(QueryBuilders.termQuery("xxx",xxx)))
.abortOnVersionConflict(false)
.get();

 


注意:本文归作者所有,未经作者允许,不得转载
所属分类:产品

全部评论: 0

    我有话说:
    ×