添加addshipfile参数

Author: dapeng

core/src/main/java/com/dtstack/flink/sql/option/Options.java

@@ -72,6 +72,10 @@ public class Options {
     @OptionRequired(description = "log level")
     private String logLevel = "info";
 
+    @OptionRequired(description = "file add to ship file")
+    private  String addShipfile;
+
+
     public String getMode() {
         return mode;
     }
@@ -183,4 +187,13 @@ public String getLogLevel() {
 	public void setLogLevel(String logLevel) {
 		this.logLevel = logLevel;
 	}
+
+    public String getAddShipfile() {
+        return addShipfile;
+    }
+
+    public void setAddShipfile(String addShipfile) {
+        this.addShipfile = addShipfile;
+    }
+
 }

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

@@ -106,6 +106,13 @@ public AbstractYarnClusterDescriptor createPerJobClusterDescriptor(String flinkJ
         } else {
             throw new RuntimeException("The Flink jar path is null");
         }
+        // add  user customized file to shipfile
+        if (!StringUtils.isBlank(launcherOptions.getAddShipfile())) {
+            List<String> paths = ConfigParseUtil.parsePathFromStr(launcherOptions.getAddShipfile());
+            paths.forEach(path -> {
+                shipFiles.add(new File(path));
+            });
+        }
         // classpath , all node need contain plugin jar
         String pluginLoadMode = launcherOptions.getPluginLoadMode();
         if (StringUtils.equalsIgnoreCase(pluginLoadMode, EPluginLoadMode.CLASSPATH.name())) {