We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 5bdbaf1 + 654a3c0 commit 38079c1Copy full SHA for 38079c1
1 file changed
core/src/main/java/com/dtstack/flink/sql/environment/StreamEnvConfigManager.java
@@ -85,8 +85,8 @@ public static void streamExecutionEnvironmentConfig(StreamExecutionEnvironment s
85
ExecutionConfig exeConfig = streamEnv.getConfig();
86
if (exeConfig.getGlobalJobParameters() == null) {
87
exeConfig.setGlobalJobParameters(globalJobParameters);
88
- } else if (exeConfig.getGlobalJobParameters() instanceof Configuration) {
89
- ((Configuration) exeConfig.getGlobalJobParameters()).addAll(globalJobParameters);
+ } else if (exeConfig.getGlobalJobParameters() instanceof ExecutionConfig.GlobalJobParameters) {
+ exeConfig.setGlobalJobParameters(globalJobParameters);
90
}
91
92
getEnvParallelism(confProperties).ifPresent(streamEnv::setParallelism);
0 commit comments