properties field trim

Author: todd5167

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

@@ -329,6 +329,8 @@ private static void registerTable(SqlTree sqlTree, StreamExecutionEnvironment en
     }
 
     private static StreamExecutionEnvironment getStreamExeEnv(Properties confProperties, String deployMode) throws Exception {
+        confProperties = propertiesTrim(confProperties);
+
         StreamExecutionEnvironment env = !ClusterMode.local.name().equals(deployMode) ?
                 StreamExecutionEnvironment.getExecutionEnvironment() :
                 new MyLocalStreamEnvironment();
@@ -370,4 +372,14 @@ private static StreamExecutionEnvironment getStreamExeEnv(Properties confPropert
 
         return env;
     }
+
+    private static Properties propertiesTrim(Properties confProperties) {
+        Properties properties = new Properties();
+        confProperties.forEach(
+                (k, v) -> {
+                    properties.put(k.toString().trim(), v.toString().trim());
+                }
+        );
+        return properties;
+    }
 }