下面的代码在记录数较高时在客户端（elasticsearch客户端）中返回超时。
CompletableFuture<BulkByScrollResponse> future = new CompletableFuture<>();
client.reindexAsync(request, RequestOptions.DEFAULT, new ActionListener<BulkByScrollResponse>() {
@Override
public void onResponse(BulkByScrollResponse bulkByScrollResponse) {
future.complete(bulkByScrollResponse);
}
@Override
public void onFailure(Exception e) {
future.completeExceptionally(e);
}
});
BulkByScrollResponse response = future.get(10, TimeUnit.MINUTES); // client timeout occured before this timeout下面是客户端配置。
connectTimeout: 60000
socketTimeout: 600000
maxRetryTimeoutMillis: 600000有没有办法无限期地等到重新索引完成？
1条答案
按热度按时间carvr3hs1#
我不认为它是一个更好的选择，无限期地等待完成重新索引过程，并给予非常高的超时值，因为这不是一个正确的修复，将造成更多的弊大于利。
相反，您应该检查响应，添加更多调试日志，以找到根本原因并解决它们。另外，请看一下我的提示，以提高重新索引速度，这应该会解决一些潜在的问题。