From 36d753eacb926c08a1d9c985e1607d51b09eabe7 Mon Sep 17 00:00:00 2001
From: qiye <jianliang5669@gmail.com>
Date: Wed, 7 Feb 2024 20:12:43 +0800
Subject: [PATCH] [opt](ES catalog) Increase to 3 connect attempts per node
 (#30957)

---
 .../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 3ed68d7471..0604926527 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) {