(inlong) branch master updated: [INLONG-11533][Manager] Enable Manager to use multiple scheduling engines simultaneously (#11534)

[aloyszhang]

This is an automated email from the ASF dual-hosted git repository.

aloyszhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 917c82c1b0 [INLONG-11533][Manager] Enable Manager to use multiple 
scheduling engines simultaneously (#11534)
917c82c1b0 is described below

commit 917c82c1b0b095e037cf4b622bf6cff954be7929
Author: Zkplo <87751516+zk...@users.noreply.github.com>
AuthorDate: Sun Nov 24 11:55:51 2024 +0800

    [INLONG-11533][Manager] Enable Manager to use multiple scheduling engines 
simultaneously (#11534)
---
 .../inlong/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 @@ public class ScheduleOperatorImpl implements 
ScheduleOperator {
     }
 
     private ScheduleEngineClient getScheduleEngineClient(String 
scheduleEngine) {
-        if (scheduleEngineClient == null) {
-            scheduleEngineClient = 
scheduleClientFactory.getInstance(scheduleEngine);
-        }
-        return scheduleEngineClient;
+        return scheduleClientFactory.getInstance(scheduleEngine);
     }
 
     @Override