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; }