bugfix

Author: maqi

core/src/main/java/com/dtstack/flink/sql/util/PluginUtil.java

@@ -160,10 +160,6 @@ public boolean accept(File dir, String name) {
             }
         }
 
-        if (StringUtils.isEmpty(coreJarFileName)){
-            throw new Exception("Can not find core jar file in path:" + path);
-        }
-
         return coreJarFileName;
     }
 

launcher/src/main/java/com/dtstack/flink/sql/launcher/perjob/PerJobSubmitter.java

@@ -52,16 +52,16 @@ public class PerJobSubmitter {
     public static String submit(LauncherOptions launcherOptions, JobGraph jobGraph) throws Exception {
 
 		fillJobGraphClassPath(jobGraph);
-
-		String addjarPath = URLDecoder.decode(launcherOptions.getAddjar(), Charsets.UTF_8.toString());
-		if (StringUtils.isNotBlank(addjarPath) ){
+		if (StringUtils.isNoneEmpty(launcherOptions.getAddjar())) {
+			String addjarPath = URLDecoder.decode(launcherOptions.getAddjar(), Charsets.UTF_8.toString());
 			List<String>  paths = getJarPaths(addjarPath);
 			paths.forEach( path ->{
 				jobGraph.addJar(new Path("file://" + path));
 			});
-
 		}
 
+
+
 		String confProp = launcherOptions.getConfProp();
         confProp = URLDecoder.decode(confProp, Charsets.UTF_8.toString());
         Properties confProperties = PluginUtil.jsonStrToObject(confProp, Properties.class);