在安装 xpack 之前,我能够批量索引文档。安装 xpack 后,我得到failure in bulk execution:
. 我正在为 xpack 使用 java 客户端
<dependency>
<groupId>org.elasticsearch.client</groupId>
<artifactId>x-pack-transport</artifactId>
<version>5.5.1</version>
</dependency>
并通过连接到 ES 服务器
client = new PreBuiltXPackTransportClient(Settings.builder()
.put("cluster.name", "name")
.put("xpack.security.user", "user:pass")
.build())
.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("ip"), 9300));
和批量索引
try {
BulkResponse r = bulkRequest.get();
System.out.println("number of actions :
"+bulkRequest.numberOfActions()); // prints 29
System.out.println(r.buildFailureMessage()); // prints failure in bulk
execution:
for(BulkItemResponse a : r.getItems()){
System.out.println("failure message : "+a.getFailureMessage()); //failure message : null
System.out.println("response : "+a.getResponse()); // prints response : IndexResponse[index=bigmart_bill_store_id,type=bill_store_id,id=AWCWJzhqNaFB56dBfQnX,version=1,result=created,shards={"total":2,"successful":1,"failed":0}]
System.out.println("failure : "+a.getFailure()); // prints failure message : null
}
new ConfigureES().client.close();
} catch (Exception we) {
we.printStackTrace();
}
此代码在安装 xpack 之前运行良好。现在它给了我错误。我没有收到任何异常或任何错误堆栈跟踪,我无法批量索引
我将提供调试此错误所需的任何信息