From f855fdd925232699b2ca7487e84a6d91e31967f7 Mon Sep 17 00:00:00 2001
From: ZKpLo <14148880+zkplo@user.noreply.gitee.com>
Date: Fri, 22 Nov 2024 10:29:07 +0800
Subject: [PATCH] [INLONG-11533][Manager] Enable Manager to use multiple
 scheduling engines simultaneously

---
 .../manager/service/schedule/ScheduleOperatorImpl.java     | 7 +------
 1 file changed, 1 insertion(+), 6 deletions(-)

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