diff --git a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ExecutorServiceImpl.java b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ExecutorServiceImpl.java index 765c5c7a38..5a31c8efdd 100644 --- a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ExecutorServiceImpl.java +++ b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ExecutorServiceImpl.java @@ -1274,9 +1274,8 @@ public class ExecutorServiceImpl extends BaseServiceImpl implements ExecutorServ */ private String removeDuplicates(String scheduleTimeList) { if (StringUtils.isNotEmpty(scheduleTimeList)) { - Set dateSet = - Arrays.stream(scheduleTimeList.split(COMMA)).map(String::trim).collect(Collectors.toSet()); - return String.join(COMMA, dateSet); + return Arrays.stream(scheduleTimeList.split(COMMA)).map(String::trim).distinct() + .collect(Collectors.joining(COMMA)); } return null; }