在 Java 中避免 Elasticsearch 重新索引超时

Question

当记录数较高时，以下代码在客户端（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

有没有办法无限期地等待重新索引完成？

Answer 1

我认为无限期地等待完成重新索引过程并为超时设置很高的值并不是一个更好的选择，因为这不是一个适当的解决方法，而且弊大于利。

您应该检查响应，添加更多调试日志以找出根本原因并解决它们。另外请查看my tips to improve re-indexing speed，它应该可以解决您的一些潜在问题。