Elastic Search：解决UpdateByQuery删除嵌套对象元素的冲突错误

首先，你遇到的Conflict错误本质是**乐观并发控制（OCC）**导致的：当_update_by_query执行时，Elasticsearch会校验文档版本，如果在查询到文档和更新文档的间隙，有其他操作修改了该文档（或者同一批次内多个更新操作影响了同一文档），就会抛出版本冲突。加上你有多个uid:123的文档，这个冲突概率会更高。

下面给你几个可行的解决方案，按推荐程度排序：

1. 启用自动重试机制（最直接的解决方式） #

_update_by_query支持通过参数设置自动重试冲突文档，同时我们需要优化脚本避免手动遍历的索引错位问题：

POST test/_update_by_query?conflicts=proceed&retry_on_conflict=5
{
  "script": {
    "source": "// 先收集所有要删除的元素索引
      def toRemove = [];
      for(int i=0; i<ctx._source.address.size(); i++){
        if(ctx._source.address[i].city == params.city && ctx._source.address[i].state == params.state){
          toRemove.add(i);
        }
      }
      // 倒序删除，避免正序删除导致的索引偏移问题
      for(int i = toRemove.size()-1; i >=0; i--){
        ctx._source.address.remove(toRemove[i]);
      }",
    "params": {
      "city": "Mumbai",
      "state": "Maharashtra"
    }
  },
  "query": {
    "bool": {
      "must": [{
        "term": {
          "uid": "123"
        }
      }]
    }
  }
}

关键说明：

• conflicts=proceed：告诉ES遇到冲突时跳过当前失败的文档，继续处理其他文档，最终会返回冲突的文档数量。
• retry_on_conflict=5：每个冲突文档最多重试5次，大幅提升成功概率。
• 脚本优化：正序遍历删除元素会导致后续元素索引错位（比如删除索引0后，原索引1的元素变成了索引0，下一次循环会跳过它），所以先收集索引再倒序删除，确保每个目标元素都被正确移除。

2. 使用Painless脚本的简洁写法（更可靠） #

你可以用Painless支持的Java集合removeIf方法简化脚本，内部自动处理遍历和删除逻辑，避免手动循环的错误：

POST test/_update_by_query?conflicts=proceed
{
  "script": {
    "source": "ctx._source.address.removeIf(item -> item.city == params.city && item.state == params.state);",
    "params": {
      "city": "Mumbai",
      "state": "Maharashtra"
    }
  },
  "query": {
    "bool": {
      "must": [{
        "term": {
          "uid": "123"
        }
      }]
    }
  }
}

这个写法不仅简洁，还从根源上避免了手动遍历可能出现的索引问题，推荐优先使用。

3. 缩小查询范围，降低冲突概率 #

如果uid不是唯一键，可以结合其他条件（比如时间范围、其他字段）缩小查询到的文档数量，减少同一时间修改的文档数，自然降低冲突概率：

POST test/_update_by_query?conflicts=proceed
{
  "script": {
    "source": "ctx._source.address.removeIf(item -> item.city == params.city && item.state == params.state);",
    "params": {
      "city": "Mumbai",
      "state": "Maharashtra"
    }
  },
  "query": {
    "bool": {
      "must": [
        {"term": {"uid": "123"}},
        {"range": {"create_time": {"gte": "2024-01-01"}}}
      ]
    }
  }
}

4. 异步执行大批次任务 #

如果需要处理的文档量很大，建议开启异步执行避免请求超时，同时可以跟踪任务进度：

POST test/_update_by_query?conflicts=proceed&wait_for_completion=false
{
  // 脚本和查询内容同上
}

执行后会返回一个任务ID，你可以通过GET _tasks/{task_id}查看任务的进度、成功数、冲突数等结果。

总结一下：最推荐的组合是启用重试机制+使用removeIf简洁脚本，既解决冲突问题，又避免脚本逻辑错误。

内容的提问来源于stack exchange，提问作者Suraj Dalvi