修复任务初始化参数未生效

Author: dapeng

core/src/main/java/com/dtstack/flink/sql/environment/StreamEnvConfigManager.java

@@ -87,8 +87,8 @@ public static void streamExecutionEnvironmentConfig(StreamExecutionEnvironment s
         ExecutionConfig exeConfig = streamEnv.getConfig();
         if (exeConfig.getGlobalJobParameters() == null) {
             exeConfig.setGlobalJobParameters(globalJobParameters);
-        } else if (exeConfig.getGlobalJobParameters() instanceof Configuration) {
-            ((Configuration) exeConfig.getGlobalJobParameters()).addAll(globalJobParameters);
+        } else if (exeConfig.getGlobalJobParameters() instanceof ExecutionConfig.GlobalJobParameters) {
+            exeConfig.setGlobalJobParameters(globalJobParameters);
         }
 
         getEnvParallelism(confProperties).ifPresent(streamEnv::setParallelism);