[INLONG-11533][Manager] Enable Manager to use multiple scheduling eng…

…ines simultaneously
apache · Nov 22, 2024 · f855fdd · f855fdd
1 parent 3700baa
commit f855fdd
Showing 1 changed file with 1 addition and 6 deletions.
diff --git a/...ervice/src/main/java/org/apache/inlong/manager/service/schedule/ScheduleOperatorImpl.java b/...ervice/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