修复作业非remote作业进行remote语法校验的问题

dlink-admin/src/main/java/com/dlink/service/impl/StudioServiceImpl.java

@@ -87,6 +87,9 @@ public class StudioServiceImpl implements StudioService {
         JobConfig config = studioExecuteDTO.getJobConfig();
         // If you are using a shared session, configure the current jobmanager address
         if(!config.isUseSession()) {
+            if(GatewayType.LOCAL.equalsValue(config.getType())){
+                config.setUseRemote(false);
+            }
             config.setAddress(clusterService.buildEnvironmentAddress(config.isUseRemote(), studioExecuteDTO.getClusterId()));
         }
         initUDF(config,studioExecuteDTO.getStatement());
@@ -132,6 +135,9 @@ public class StudioServiceImpl implements StudioService {
     public IResult executeDDL(StudioDDLDTO studioDDLDTO) {
         JobConfig config = studioDDLDTO.getJobConfig();
         if(!config.isUseSession()) {
+            if(GatewayType.LOCAL.equalsValue(config.getType())){
+                config.setUseRemote(false);
+            }
             config.setAddress(clusterService.buildEnvironmentAddress(config.isUseRemote(), studioDDLDTO.getClusterId()));
         }
         JobManager jobManager = JobManager.build(config);
@@ -151,6 +157,9 @@ public class StudioServiceImpl implements StudioService {
         addFlinkSQLEnv(studioExecuteDTO);
         JobConfig config = studioExecuteDTO.getJobConfig();
         if(!config.isUseSession()) {
+            if(GatewayType.LOCAL.equalsValue(config.getType())){
+                config.setUseRemote(false);
+            }
             config.setAddress(clusterService.buildEnvironmentAddress(config.isUseRemote(), studioExecuteDTO.getClusterId()));
         }
         initUDF(config,studioExecuteDTO.getStatement());
@@ -183,6 +192,9 @@ public class StudioServiceImpl implements StudioService {
         JobConfig config = studioExecuteDTO.getJobConfig();
         config.setType(GatewayType.LOCAL.getLongValue());
         if(!config.isUseSession()) {
+            if(GatewayType.LOCAL.equalsValue(config.getType())){
+                config.setUseRemote(false);
+            }
             config.setAddress(clusterService.buildEnvironmentAddress(config.isUseRemote(), studioExecuteDTO.getClusterId()));
         }
         JobManager jobManager = JobManager.buildPlanMode(config);
@@ -195,6 +207,9 @@ public class StudioServiceImpl implements StudioService {
         JobConfig config = studioExecuteDTO.getJobConfig();
         config.setType(GatewayType.LOCAL.getLongValue());
         if(!config.isUseSession()) {
+            if(GatewayType.LOCAL.equalsValue(config.getType())){
+                config.setUseRemote(false);
+            }
             config.setAddress(clusterService.buildEnvironmentAddress(config.isUseRemote(), studioExecuteDTO.getClusterId()));
         }
         JobManager jobManager = JobManager.buildPlanMode(config);

dlink-admin/src/main/java/com/dlink/service/impl/TaskServiceImpl.java

@@ -176,6 +176,9 @@ public class TaskServiceImpl extends SuperServiceImpl<TaskMapper, Task> implemen
         JobConfig config = task.buildSubmitConfig();
         config.setJarTask(isJarTask);
         if (!JobManager.useGateway(config.getType())) {
+            if(GatewayType.LOCAL.equalsValue(config.getType())){
+                config.setUseRemote(false);
+            }
             config.setAddress(clusterService.buildEnvironmentAddress(config.isUseRemote(), task.getClusterId()));
         } else {
             Map<String, Object> gatewayConfig = clusterConfigurationService.getGatewayConfig(task.getClusterConfigurationId());