使用Elasticsearch 8.7 Java客户端更新记录时原有字段被清空问题

我尝试为Elasticsearch中的一条现有记录添加几个新字段，但更新后该记录的所有已索引字段都被清空了。请问我哪里操作出错了？

Maven依赖 #

<dependency>
   <groupId>co.elastic.clients</groupId>
   <artifactId>elasticsearch-java</artifactId>
   <version>8.7.1</version>
</dependency>

我的代码 #

RestClientBuilder builder = RestClient.builder(new HttpHost(esIP, Integer.parseInt(esPort)));

RestClient restClient = builder.build();

// jsonMap表示要索引的一条记录
br.operations(op -> op.index(idx -> idx.index((String) jsonMap.get("index_name")).id(jsonMap.get("id").toString()).document(jsonMap)));

问题原因与解决办法 #

你用错了API操作：当前代码里的index操作是全量替换文档——如果目标ID的文档已经存在，Elasticsearch会直接用你传入的jsonMap覆盖原有完整文档。如果你的jsonMap里只包含新增字段和index_name、id，原有字段自然会被全部清空。

要实现增量添加字段，必须使用update操作，它会保留原有文档的所有字段，只更新你指定的内容。

修改后的代码示例：

RestClientBuilder builder = RestClient.builder(new HttpHost(esIP, Integer.parseInt(esPort)));
ElasticsearchClient client = new ElasticsearchClient(new RestClientTransport(builder.build(), new JacksonJsonpMapper()));

// 假设你要新增的字段放在一个单独的map里
Map<String, Object> newFieldsMap = new HashMap<>();
newFieldsMap.put("new_field1", "value1");
newFieldsMap.put("new_field2", 123);

// 执行update操作
UpdateResponse<Void> response = client.update(u -> u
        .index((String) jsonMap.get("index_name"))
        .id(jsonMap.get("id").toString())
        .doc(newFieldsMap), // 传入要新增/更新的字段
        Void.class
);

如果你的jsonMap里既有原有字段又有新增字段，也可以直接传入jsonMap到doc方法，但更推荐只传入需要修改的字段，减少不必要的数据传输。

内容的提问来源于stack exchange，提问作者Phani Varma