diff --git a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/schedule/ScheduleOperatorImpl.java b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/schedule/ScheduleOperatorImpl.java index 6ef899ab9e..c00bb24fc4 100644 --- a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/schedule/ScheduleOperatorImpl.java +++ b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/schedule/ScheduleOperatorImpl.java @@ -59,8 +59,6 @@ public class ScheduleOperatorImpl implements ScheduleOperator { private OfflineJobOperator offlineJobOperator; - private ScheduleEngineClient scheduleEngineClient; - @Override @Transactional(rollbackFor = Throwable.class) public int saveOpt(ScheduleInfoRequest request, String operator) { @@ -89,10 +87,7 @@ private void registerScheduleInfoForApprovedGroup(ScheduleInfo scheduleInfo, Str } private ScheduleEngineClient getScheduleEngineClient(String scheduleEngine) { - if (scheduleEngineClient == null) { - scheduleEngineClient = scheduleClientFactory.getInstance(scheduleEngine); - } - return scheduleEngineClient; + return scheduleClientFactory.getInstance(scheduleEngine); } @Override