[Improve] scala map bug fixed.

apache · Oct 5, 2024 · 5a03657 · 5a03657
1 parent 5b9e809
commit 5a03657
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...hims-base/src/main/scala/org/apache/streampark/flink/core/FlinkStreamingInitializer.scala b/...hims-base/src/main/scala/org/apache/streampark/flink/core/FlinkStreamingInitializer.scala
@@ -105,7 +105,7 @@ private[flink] class FlinkStreamingInitializer(args: Array[String], apiType: Api
       }
     }
 
-    val envConfig = Configuration.fromMap(flinkConf + appFlinkConf)
+    val envConfig = Configuration.fromMap(flinkConf ++ appFlinkConf)
     FlinkConfiguration(parameter, envConfig, null)
   }
 

diff --git a/...nk-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkTableInitializer.scala b/...nk-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkTableInitializer.scala
@@ -197,7 +197,7 @@ private[flink] class FlinkTableInitializer(args: Array[String], apiType: ApiType
           }
         }
 
-        val envConfig = Configuration.fromMap(flinkConf + appFlinkConf)
+        val envConfig = Configuration.fromMap(flinkConf ++ appFlinkConf)
         val tableConfig = Configuration.fromMap(tableConf)
 
         val parameterTool = ParameterTool