protected List<File> getShipFiles(String flinkJarPath, String pluginLoadMode, JobGraph jobGraph, YarnClusterDescriptor clusterDescriptor)
            throws MalformedURLException {

        List<File> shipFiles = new ArrayList<>();
        dealFlinkLibJar(flinkJarPath, clusterDescriptor, shipFiles);
        dealUserJarByPluginLoadMode(pluginLoadMode, jobGraph, shipFiles);
        return shipFiles;
    }
Date: 2020/3/4
Company: www.dtstack.com
@author maqi
launcher/src/main/java/com/dtstack/flink/sql/launcher/executor/YarnJobClusterExecutor.java