Skip to content

D
dlink
Commit 9b87e2da authored by wuhuiqiang2's avatar wuhuiqiang2
Browse files
Options

Fix flinkLibPath in K8S configuration is null

parent 1b3a4d5b
Show whitespace changes
Inline Side-by-side
Showing with 1 addition and 3 deletions
dlink-core/src/main/java/com/dlink/job/JobConfig.java
View file @ 9b87e2da
...@@ -168,9 +168,7 @@ public class JobConfig { ...@@ -168,9 +168,7 @@ public class JobConfig {
config.get("flinkLibPath").toString(), config.get("flinkLibPath").toString(),
config.get("hadoopConfigPath").toString())); config.get("hadoopConfigPath").toString()));
} else { } else {
gatewayConfig.setClusterConfig(ClusterConfig.build(config.get("flinkConfigPath").toString(), gatewayConfig.setClusterConfig(ClusterConfig.build(config.get("flinkConfigPath").toString()));
config.get("flinkLibPath").toString(),
""));
} }
AppConfig appConfig = new AppConfig(); AppConfig appConfig = new AppConfig();
if (config.containsKey("userJarPath") && Asserts.isNotNullString((String) config.get("userJarPath"))) { if (config.containsKey("userJarPath") && Asserts.isNotNullString((String) config.get("userJarPath"))) {
......
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