ES Java API修改字段映射后updateByQuery异常，求免重索引方案

首先明确：完全可以不用全量重索引实现你的需求，但你之前的操作有两个关键错误导致updateByQuery没生效。我来一步步拆解问题和修复方案：

1. 先搞懂官方文档的“矛盾”其实是互补的 #

你看到的两条文档说明并不冲突：

"Templates are only applied at index creation time. Changing a template will have no impact on existing indices..."
这条说的是模板只对新创建的索引生效，修改模板后，已存在的索引必须手动更新映射，不能指望模板自动同步。

"The simplest usage of _update_by_query just performs an update on every document in the index without changing the source. This is useful to pick up a new property or some other online mapping change."
这条说的是，当你手动更新了现有索引的映射后，用updateByQuery可以触发ES重新处理所有文档，自动生成新映射对应的字段（比如你新增的subject.sort和subject.sortConversation子字段），无需修改源文档内容。

2. 你之前的PutMapping操作完全无效 #

你的代码里写了：

.setSource("{\"properties\": {}}")

这等于给索引的email类型设置了一个空的properties映射，根本没有把你需要的新subject字段映射加进去！这就是为什么后续updateByQuery没效果——ES根本不知道有新的子字段要生成。

正确的PutMapping代码 #

你需要把完整的subject字段映射写入现有索引：

// 构造新的subject映射JSON字符串
String newSubjectMapping = "{\"properties\": {\"subject\": {\"type\": \"string\", \"fields\": {\"sort\": {\"type\": \"string\", \"analyzer\": \"ducet_sort_subject\"}, \"sortConversation\": {\"type\": \"string\", \"analyzer\": \"ducet_sort_subject_conversation\"}}}}}";

// 更新现有索引的映射
PutMappingResponse putMappingResponse = client.admin().indices()
    .preparePutMapping(indexName)
    .setType("email") // ES7+版本可以省略，默认使用_doc类型
    .setSource(newSubjectMapping)
    .execute()
    .actionGet();

// 验证映射是否更新成功
if (putMappingResponse.isAcknowledged()) {
    System.out.println("映射更新成功！");
} else {
    System.err.println("映射更新失败，请检查JSON格式或权限！");
}

执行完这一步后，一定要用ES的REST API验证映射是否真的生效：

GET /your_index_name/_mapping/email

确认返回的结果里包含subject的fields配置。

3. 正确执行updateByQuery触发字段生成 #

映射更新成功后，再执行updateByQuery，ES会重新处理每一篇文档，根据新映射生成subject.sort和subject.sortConversation的内容。注意不需要写任何脚本，因为我们只是让ES重新解析源文档的subject字段，应用新的分析器生成子字段：

BulkIndexByScrollResponse bulkResponse = UpdateByQueryAction.INSTANCE.newRequestBuilder(client)
    .source(indexName)
    .setType("email") // 同样，ES7+可省略
    .setConflicts("proceed") // 遇到版本冲突时继续执行，根据你的业务需求调整
    .setBatchSize(1000) // 设置批次大小，避免占用过多集群资源
    .execute()
    .actionGet();

// 打印执行结果
System.out.println("处理的文档总数：" + bulkResponse.getTotal());
System.out.println("成功更新的文档数：" + bulkResponse.getUpdated());
System.out.println("失败的文档数：" + bulkResponse.getFailed());

4. 关键注意事项 #

• ES版本兼容性：如果你用的是ES7及以上，type已经被弃用，建议去掉setType("email")，或者替换为setType("_doc")。
• 集群资源占用：updateByQuery会消耗CPU和IO资源，建议在业务低峰期执行，或者使用切片updateByQuery（通过setSlices()方法）并行处理大索引。
• 验证结果：执行完成后，随机查询几篇文档，检查subject.sort和subject.sortConversation是否已经生成：

  GET /your_index_name/email/_search
  {
    "query": {"match_all": {}},
    "_source": ["subject", "subject.sort", "subject.sortConversation"]
  }
  

这样操作后，你就不需要全量重索引，就能让现有文档用上新的字段映射了。

内容的提问来源于stack exchange，提问作者Luigi Cirillo