fix sql urlencode

Author: xiuzhu9527

flinkx-core/src/main/java/com/dtstack/flinkx/Main.java

@@ -71,6 +71,8 @@
 import org.slf4j.LoggerFactory;
 
 import java.net.URL;
+import java.net.URLDecoder;
+import java.nio.charset.StandardCharsets;
 import java.util.Arrays;
 import java.util.List;
 import java.util.Optional;
@@ -93,7 +95,7 @@ public static void main(String[] args) throws Exception {
         LOG.info("-------------------------------------------");
 
         Options options = new OptionParser(args).getOptions();
-        String job = options.getJob();
+        String job = URLDecoder.decode(options.getJob(), StandardCharsets.UTF_8.name());
         Properties confProperties = PropertiesUtil.parseConf(options.getConfProp());
         StreamExecutionEnvironment env = EnvFactory.createStreamExecutionEnvironment(options);
         StreamTableEnvironment tEnv =
@@ -313,7 +315,7 @@ private static void configStreamExecutionEnvironment(
             factoryHelper.setRemotePluginPath(options.getRemoteFlinkxDistDir());
             factoryHelper.setPluginLoadMode(options.getPluginLoadMode());
             factoryHelper.setEnv(env);
-            factoryHelper.setOptions(options);
+            factoryHelper.setExecutionMode(options.getMode());
 
             DirtyConf dirtyConf = DirtyConfUtil.parse(options);
             factoryHelper.registerCachedFile(

flinkx-core/src/main/java/com/dtstack/flinkx/util/FactoryHelper.java

@@ -18,7 +18,6 @@
 package com.dtstack.flinkx.util;
 
 import com.dtstack.flinkx.constants.ConstantValue;
-import com.dtstack.flinkx.options.Options;
 
 import org.apache.flink.configuration.ConfigOption;
 import org.apache.flink.configuration.ConfigOptions;
@@ -61,8 +60,8 @@ public class FactoryHelper {
     protected List<URL> classPathSet = new ArrayList<>();
     /** shipfile需要的jar的classPath index */
     protected int classFileNameIndex = 0;
-    /** 任务启动参数 */
-    protected Options options;
+    /** 任务执行模式 */
+    protected String executionMode;
 
     public FactoryHelper() {}
 
@@ -94,7 +93,7 @@ public void registerCachedFile(
                     this.classFileNameIndex++;
                 }
             }
-            PluginUtil.setPipelineOptionsToEnvConfig(this.env, urlList, options);
+            PluginUtil.setPipelineOptionsToEnvConfig(this.env, urlList, executionMode);
         } catch (Exception e) {
             LOG.warn("can't add jar in {} to cachedFile, e = {}", urlSet, e.getMessage());
         }
@@ -116,11 +115,11 @@ public void setEnv(StreamExecutionEnvironment env) {
         this.env = env;
     }
 
-    public Options getOptions() {
-        return options;
+    public String getExecutionMode() {
+        return executionMode;
     }
 
-    public void setOptions(Options options) {
-        this.options = options;
+    public void setExecutionMode(String executionMode) {
+        this.executionMode = executionMode;
     }
 }

flinkx-core/src/main/java/com/dtstack/flinkx/util/PluginUtil.java

@@ -346,7 +346,7 @@ public static void registerPluginUrlToCachedFile(
                     e);
         }
 
-        config.setSyncJarList(setPipelineOptionsToEnvConfig(env, urlList, options));
+        config.setSyncJarList(setPipelineOptionsToEnvConfig(env, urlList, options.getMode()));
     }
 
     /**
@@ -358,7 +358,7 @@ public static void registerPluginUrlToCachedFile(
      */
     @SuppressWarnings("all")
     public static List<String> setPipelineOptionsToEnvConfig(
-            StreamExecutionEnvironment env, List<String> urlList, Options options) {
+            StreamExecutionEnvironment env, List<String> urlList, String executionMode) {
         try {
             Configuration configuration =
                     (Configuration)
@@ -370,7 +370,6 @@ public static List<String> setPipelineOptionsToEnvConfig(
             jarList.addAll(urlList);
 
             List<String> pipelineJars = new ArrayList();
-            String executionMode = options.getMode();
             LOG.info("Flinkx executionMode: " + executionMode);
             if (ClusterMode.getByName(executionMode) == ClusterMode.kubernetesApplication) {
                 for (String jarUrl : jarList) {