fix parse bug

Author: todd5167

core/src/main/java/com/dtstack/flink/sql/Main.java

@@ -40,17 +40,12 @@
 import org.apache.calcite.config.Lex;
 import org.apache.calcite.sql.SqlInsert;
 import org.apache.calcite.sql.SqlNode;
-import org.apache.commons.cli.CommandLine;
-import org.apache.commons.cli.CommandLineParser;
-import org.apache.commons.cli.DefaultParser;
-import org.apache.commons.cli.Options;
 import org.apache.commons.io.Charsets;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.flink.api.common.restartstrategy.RestartStrategies;
 import org.apache.flink.api.common.time.Time;
 import org.apache.flink.api.common.typeinfo.TypeInformation;
 import org.apache.flink.api.java.typeutils.RowTypeInfo;
-import org.apache.flink.calcite.shaded.com.google.common.base.Preconditions;
 import org.apache.flink.calcite.shaded.com.google.common.base.Strings;
 import org.apache.flink.calcite.shaded.com.google.common.collect.Lists;
 import org.apache.flink.calcite.shaded.com.google.common.collect.Maps;

launcher/src/main/java/com/dtstack/flink/sql/launcher/LauncherMain.java

@@ -67,13 +67,11 @@ public static void main(String[] args) throws Exception {
         String mode = launcherOptions.getMode();
         List<String> argList = optionParser.getProgramExeArgList();
         if(mode.equals(ClusterMode.local.name())) {
-            //String[] localArgs = argList.toArray(new String[argList.size()]);
             Main.main(args);
         }else{
             String pluginRoot = launcherOptions.getLocalSqlPluginPath();
             File jarFile = new File(getLocalCoreJarPath(pluginRoot));
-            String[] remoteArgs = argList.toArray(new String[argList.size()]);
-            PackagedProgram program = new PackagedProgram(jarFile, Lists.newArrayList(), remoteArgs);
+            PackagedProgram program = new PackagedProgram(jarFile, Lists.newArrayList(), args);
             if(StringUtils.isNotBlank(launcherOptions.getSavePointPath())){
                 program.setSavepointRestoreSettings(SavepointRestoreSettings.forPath(launcherOptions.getSavePointPath(), BooleanUtils.toBoolean(launcherOptions.getAllowNonRestoredState())));
             }