We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0f15d10 commit 9476f03Copy full SHA for 9476f03
launcher/src/main/java/com/dtstack/flink/sql/launcher/perjob/PerJobSubmitter.java
@@ -52,10 +52,10 @@ public class PerJobSubmitter {
52
public static String submit(LauncherOptions launcherOptions, JobGraph jobGraph) throws Exception {
53
54
fillJobGraphClassPath(jobGraph);
55
- if (StringUtils.isNoneEmpty(launcherOptions.getAddjar())) {
+ if (!StringUtils.isBlank(launcherOptions.getAddjar())) {
56
String addjarPath = URLDecoder.decode(launcherOptions.getAddjar(), Charsets.UTF_8.toString());
57
List<String> paths = getJarPaths(addjarPath);
58
- paths.forEach( path ->{
+ paths.forEach( path -> {
59
jobGraph.addJar(new Path("file://" + path));
60
});
61
}
0 commit comments