jar exist check

Author: todd5167

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

@@ -111,15 +111,15 @@ public static URL getRemoteJarFilePath(String pluginType, String tableType, Stri
         String dirName = pluginType + tableType.toLowerCase();
         String prefix = String.format("%s-%s", pluginType, tableType.toLowerCase());
         String jarPath = remoteSqlRootDir + SP + dirName;
-        String jarName = getCoreJarFileName(jarPath, prefix);
+        String jarName = getCoreJarFileName(jarPath, prefix, false);
         return new URL("file:" + remoteSqlRootDir + SP + dirName + SP + jarName);
     }
 
     public static URL getRemoteSideJarFilePath(String pluginType, String sideOperator, String tableType, String remoteSqlRootDir) throws Exception {
         String dirName = pluginType + sideOperator + tableType.toLowerCase();
         String prefix = String.format("%s-%s-%s", pluginType, sideOperator, tableType.toLowerCase());
         String jarPath = remoteSqlRootDir + SP + dirName;
-        String jarName = getCoreJarFileName(jarPath, prefix);
+        String jarName = getCoreJarFileName(jarPath, prefix, false);
         return new URL("file:" + remoteSqlRootDir + SP + dirName + SP + jarName);
     }
 
@@ -144,7 +144,11 @@ public static void addPluginJar(String pluginDir, DtClassLoader classLoader) thr
         }
     }
 
-    public static String getCoreJarFileName (String path, String prefix) throws Exception {
+    public static String getCoreJarFileName (String path, String prefix, boolean existCheck) throws Exception {
+        if (!existCheck) {
+            return prefix.toLowerCase() + ".jar";
+        }
+
         String coreJarFileName = null;
         File pluginDir = new File(path);
         if (pluginDir.exists() && pluginDir.isDirectory()){
@@ -158,10 +162,11 @@ public boolean accept(File dir, String name) {
             if (jarFiles != null && jarFiles.length > 0){
                 coreJarFileName = jarFiles[0].getName();
             }
-        }else {
-            coreJarFileName = prefix.toLowerCase() + ".jar";
         }
 
+        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/LauncherMain.java

@@ -59,7 +59,7 @@ public class LauncherMain {
 
 
     private static String getLocalCoreJarPath(String localSqlRootJar) throws Exception {
-        String jarPath = PluginUtil.getCoreJarFileName(localSqlRootJar, CORE_JAR);
+        String jarPath = PluginUtil.getCoreJarFileName(localSqlRootJar, CORE_JAR, true);
         String corePath = localSqlRootJar + SP + jarPath;
         return corePath;
     }