From 9d3a017706ae2914ff7b325f3d809f89f5aee882 Mon Sep 17 00:00:00 2001 From: caoliang-web <71004656+caoliang-web@users.noreply.github.com> Date: Fri, 12 Jan 2024 16:35:48 +0800 Subject: [PATCH] [fix](doriswriter)Fix the problem that specifying multiple loadurls does not take effect #29865 --- .../writer/doriswriter/DorisStreamLoadObserver.java | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) diff --git a/extension/DataX/doriswriter/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/DorisStreamLoadObserver.java b/extension/DataX/doriswriter/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/DorisStreamLoadObserver.java index 22bd1f4e55..2a23a07fac 100644 --- a/extension/DataX/doriswriter/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/DorisStreamLoadObserver.java +++ b/extension/DataX/doriswriter/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/DorisStreamLoadObserver.java @@ -240,12 +240,10 @@ public class DorisStreamLoadObserver { private String getLoadHost() { List 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; }