Skip to content

D
dlink
Commit 242166a0 authored by wenmo's avatar wenmo
Browse files
Options

sql导出bug修复

parent d1eb9328
Hide whitespace changes
Inline Side-by-side
Showing with 5 additions and 3 deletions
dlink-core/src/main/java/com/dlink/job/JobManager.java
View file @ 242166a0
...@@ -472,7 +472,7 @@ public class JobManager { ...@@ -472,7 +472,7 @@ public class JobManager {
if(Asserts.isNotNullString(config.getSavePointPath())){ if(Asserts.isNotNullString(config.getSavePointPath())){
sb.append("set " + SavepointConfigOptions.SAVEPOINT_PATH + " = " + config.getSavePointPath() + ";\r\n"); sb.append("set " + SavepointConfigOptions.SAVEPOINT_PATH + " = " + config.getSavePointPath() + ";\r\n");
} }
if(Asserts.isNotNull(config.getGatewayConfig().getFlinkConfig().getConfiguration())) { if(Asserts.isNotNull(config.getGatewayConfig())&&Asserts.isNotNull(config.getGatewayConfig().getFlinkConfig().getConfiguration())) {
for (Map.Entry<String, String> entry : config.getGatewayConfig().getFlinkConfig().getConfiguration().entrySet()) { for (Map.Entry<String, String> entry : config.getGatewayConfig().getFlinkConfig().getConfiguration().entrySet()) {
sb.append("set " + entry.getKey() + " = " + entry.getValue() + ";\r\n"); sb.append("set " + entry.getKey() + " = " + entry.getValue() + ";\r\n");
} }
...@@ -482,8 +482,10 @@ public class JobManager { ...@@ -482,8 +482,10 @@ public class JobManager {
case YARN_PER_JOB: case YARN_PER_JOB:
case YARN_APPLICATION: case YARN_APPLICATION:
sb.append("set " + DeploymentOptions.TARGET.key() + " = " + GatewayType.get(config.getType()).getLongValue() + ";\r\n"); sb.append("set " + DeploymentOptions.TARGET.key() + " = " + GatewayType.get(config.getType()).getLongValue() + ";\r\n");
sb.append("set " + YarnConfigOptions.PROVIDED_LIB_DIRS.key() + " = " + Collections.singletonList(config.getGatewayConfig().getClusterConfig().getFlinkLibPath()) + ";\r\n"); if(Asserts.isNotNull(config.getGatewayConfig())) {
if(Asserts.isNotNullString(config.getGatewayConfig().getFlinkConfig().getJobName())) { sb.append("set " + YarnConfigOptions.PROVIDED_LIB_DIRS.key() + " = " + Collections.singletonList(config.getGatewayConfig().getClusterConfig().getFlinkLibPath()) + ";\r\n");
}
if(Asserts.isNotNull(config.getGatewayConfig())&&Asserts.isNotNullString(config.getGatewayConfig().getFlinkConfig().getJobName())) {
sb.append("set " + YarnConfigOptions.APPLICATION_NAME.key() + " = " + config.getGatewayConfig().getFlinkConfig().getJobName() + ";\r\n"); sb.append("set " + YarnConfigOptions.APPLICATION_NAME.key() + " = " + config.getGatewayConfig().getFlinkConfig().getJobName() + ";\r\n");
} }
} }
......
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