Fix the problem that specifying multiple loadurls does not take effect

caoliang-web · Jan 11, 2024 · 62f6858 · 62f6858
1 parent ffe215b
commit 62f6858
Showing 1 changed file with 4 additions and 6 deletions.
diff --git a/...er/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/DorisStreamLoadObserver.java b/...er/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/DorisStreamLoadObserver.java
@@ -240,12 +240,10 @@ private HttpEntity getHttpEntity(CloseableHttpResponse resp) {
 
     private String getLoadHost() {
         List<String> hostList = options.getLoadUrlList();
-        long tmp = pos + hostList.size();
-        for (; pos < tmp; pos++) {
-            String host = new StringBuilder("http://").append(hostList.get((int) (pos % hostList.size()))).toString();
-            if (checkConnection(host)) {
-                return host;
-            }
+        Collections.shuffle(hostList);
+        String host = new StringBuilder("http://").append(hostList.get((0))).toString();
+        if (checkConnection(host)){
+            return host;
         }
         return null;
     }