You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by kx...@apache.org on 2024/02/07 13:48:24 UTC
(doris) branch branch-2.0 updated: [opt](ES catalog) Increase to 3 connect attempts per node (#30957) (#30969)
This is an automated email from the ASF dual-hosted git repository.
kxiao pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new 062832493b6 [opt](ES catalog) Increase to 3 connect attempts per node (#30957) (#30969)
062832493b6 is described below
commit 062832493b6452d90005fc530e5bcfa37cee196a
Author: qiye <ji...@gmail.com>
AuthorDate: Wed Feb 7 21:48:15 2024 +0800
[opt](ES catalog) Increase to 3 connect attempts per node (#30957) (#30969)
---
.../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-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org