Skip to content

D
dlink
Commit f460c1b5 authored by wangxing's avatar wangxing
Browse files
Options

修改了获取配置的逻辑问题

parent baee5b73
Show whitespace changes
Inline Side-by-side
Showing with 4 additions and 4 deletions
dlink-core/src/main/java/com/dlink/job/JobConfig.java
View file @ f460c1b5
......@@ -156,17 +156,17 @@ public class JobConfig {
config.get("flinkLibPath").toString(),
config.get("hadoopConfigPath").toString()));
AppConfig appConfig = new AppConfig();
if(config.containsKey("userJarPath") && Asserts.isNotNullString("userJarPath")){
if(config.containsKey("userJarPath") && Asserts.isNotNullString((String) config.get("userJarPath"))){
appConfig.setUserJarPath(config.get("userJarPath").toString());
if(config.containsKey("userJarMainAppClass") && Asserts.isNotNullString("userJarMainAppClass")){
if(config.containsKey("userJarMainAppClass") && Asserts.isNotNullString((String) config.get("userJarMainAppClass"))){
appConfig.setUserJarMainAppClass(config.get("userJarMainAppClass").toString());
}
if(config.containsKey("userJarParas") && Asserts.isNotNullString("userJarParas")){
if(config.containsKey("userJarParas") && Asserts.isNotNullString((String) config.get("userJarParas"))){
appConfig.setUserJarParas(config.get("userJarParas").toString().split(" "));
}
gatewayConfig.setAppConfig(appConfig);
}
if(config.containsKey("flinkConfig") && Asserts.isNotNullString("flinkConfig")){
if(config.containsKey("flinkConfig") && Asserts.isNotNullMap((Map<String, String>) config.get("flinkConfig"))){
gatewayConfig.setFlinkConfig(FlinkConfig.build((Map<String, String>)config.get("flinkConfig")));
}
}
......
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