Skip to content

D
dlink
Commit 7339ce71 authored by wenmo's avatar wenmo
Browse files
Options

修复application模式set高优先级不生效的问题

parent 51b383b4
Show whitespace changes
Inline Side-by-side
Showing with 2 additions and 0 deletions
dlink-core/src/main/java/com/dlink/job/JobManager.java
View file @ 7339ce71
...@@ -235,6 +235,7 @@ public class JobManager { ...@@ -235,6 +235,7 @@ public class JobManager {
JobGraph jobGraph = executor.getJobGraphFromInserts(inserts); JobGraph jobGraph = executor.getJobGraphFromInserts(inserts);
GatewayResult gatewayResult = null; GatewayResult gatewayResult = null;
if (GatewayType.YARN_APPLICATION.equals(runMode)) { if (GatewayType.YARN_APPLICATION.equals(runMode)) {
config.addGatewayConfig(executor.getSetConfig());
gatewayResult = Gateway.build(config.getGatewayConfig()).submitJar(); gatewayResult = Gateway.build(config.getGatewayConfig()).submitJar();
} else { } else {
config.addGatewayConfig(executor.getSetConfig()); config.addGatewayConfig(executor.getSetConfig());
...@@ -271,6 +272,7 @@ public class JobManager { ...@@ -271,6 +272,7 @@ public class JobManager {
JobGraph jobGraph = executor.getJobGraphFromInserts(inserts); JobGraph jobGraph = executor.getJobGraphFromInserts(inserts);
GatewayResult gatewayResult = null; GatewayResult gatewayResult = null;
if (GatewayType.YARN_APPLICATION.equalsValue(config.getType())) { if (GatewayType.YARN_APPLICATION.equalsValue(config.getType())) {
config.addGatewayConfig(executor.getSetConfig());
gatewayResult = Gateway.build(config.getGatewayConfig()).submitJar(); gatewayResult = Gateway.build(config.getGatewayConfig()).submitJar();
} else { } else {
config.addGatewayConfig(executor.getSetConfig()); config.addGatewayConfig(executor.getSetConfig());
......
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