This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
commit 0435219d1206e3974140566ebc3c521d65c84bab
Author: qiye <jianliang5...@gmail.com>
AuthorDate: Wed Feb 7 20:12:43 2024 +0800
[opt](ES catalog) Increase to 3 connect attempts per node (#30957)
---
.../java/org/apache/doris/external/elasticsearch/EsRestClient.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/external/elasticsearch/EsRestClient.java
b/fe/fe-core/src/main/java/org/apache/doris/external/elasticsearch/EsRestClient.java
index 3ed68d74716..06049265274 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/external/elasticsearch/EsRestClient.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/external/elasticsearch/EsRestClient.java
@@ -237,7 +237,7 @@ public class EsRestClient {
}
Request request = builder.get().url(currentNode + path).build();
if (LOG.isInfoEnabled()) {
- LOG.info("es rest client request URL: {}", currentNode + "/" +
path);
+ LOG.info("es rest client request URL: {}",
request.url().toString());
}
return httpClient.newCall(request).execute();
}
@@ -249,7 +249,8 @@ public class EsRestClient {
* @return response
*/
private String execute(String path) throws DorisEsException {
- int retrySize = nodes.length;
+ // try 3 times for every node
+ int retrySize = nodes.length * 3;
DorisEsException scratchExceptionForThrow = null;
OkHttpClient httpClient;
if (httpSslEnable) {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
