0

我是弹性搜索的初学者,我想删除大量与特定查询匹配的文档。我为此目的使用 DeleteByQueryRequest。我尝试了下面的代码。

String fileName="output2.log";
RestHighLevelClient client = new RestHighLevelClient(
RestClient.builder(new HttpHost("localhost", 9200, "http")));
DeleteByQueryRequest deleteRequest = new DeleteByQueryRequest("_all");
deleteRequest.setQuery(QueryBuilders.termQuery("fileName.keyword",fileName));
deleteRequest.setTimeout(TimeValue.timeValueMinutes(10));
//deleteRequest.setRefresh(true);
BulkByScrollResponse bulkResponse = client.deleteByQuery(deleteRequest, RequestOptions.DEFAULT);
client.close();
System.out.println(bulkResponse.isTimedOut());
System.out.print("Deletion done");

当我运行此代码时,相应的文档会被删除,但此代码会引发以下异常。

java.net.SocketTimeoutException: 30,000 milliseconds timeout on connection http-outgoing-0 [ACTIVE]

可以做些什么来摆脱这个异常?提前致谢。

4

1 回答 1

0

经过一番研究,我发现 RestHighLevelClient 的默认套接字超时为 30000 毫秒。我使用下面的代码来延长套接字超时时间。

RestHighLevelClient client = new RestHighLevelClient((RestClient.builder(new 
      HttpHost(localhost,9200,"http"))).setRequestConfigCallback(requestConfigBuilder ->                         
     requestConfigBuilder                        
    .setConnectTimeout(10000)
    .setSocketTimeout(60000)
    .setConnectionRequestTimeout(0)
));

现在您可以在 setSocketTimout() 方法中增加时间限制。

于 2021-07-12T16:38:32.240 回答