Commit ced1f7e2 authored by godkaikai's avatar godkaikai

jar application 问题修复

parent 6e231b00
......@@ -47,6 +47,7 @@ DataLink 开源项目及社区正在建设,希望本项目可以帮助你更
| | yarn session SQL提交 | 已实现 |
| | yarn per-job SQL提交 | 已实现 |
| | yarn application SQL提交 | 已实现 |
| | yarn application Jar提交 | 已实现 |
| | 作业 Cancel | 已实现 |
| | 作业 SavePoint Cancel,Stop,Trigger | 已实现 |
| | 作业从 SavePoint 恢复 | 已实现 |
......
......@@ -64,7 +64,7 @@ public class TaskServiceImpl extends SuperServiceImpl<TaskMapper, Task> implemen
config.setAddress(clusterService.buildEnvironmentAddress(config.isUseRemote(), task.getClusterId()));
} else {
Map<String, Object> gatewayConfig = clusterConfigurationService.getGatewayConfig(task.getClusterConfigurationId());
if (GatewayType.YARN_APPLICATION.equals(config.getType())) {
if (GatewayType.YARN_APPLICATION.equalsValue(config.getType())) {
if(!isJarTask) {
SystemConfiguration systemConfiguration = SystemConfiguration.getInstances();
gatewayConfig.put("userJarPath", systemConfiguration.getSqlSubmitJarPath());
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment