java - 在 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

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

相反，您应该检查响应，添加更多调试日志以找到根本原因并解决它们。另请查看我的提示以提高重新索引速度，这应该可以解决您的一些潜在问题。