[Improve] program args bug fixed.

apache · Sep 15, 2024 · 378a7d0 · 378a7d0
1 parent 5241b32
commit 378a7d0
Showing 1 changed file with 1 addition and 0 deletions.
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
@@ -196,6 +196,7 @@ private[flink] class FlinkTableInitializer(args: Array[String], apiType: ApiType
           .mergeWith(ParameterTool.fromMap(appConf))
           .mergeWith(ParameterTool.fromMap(tableConf))
           .mergeWith(ParameterTool.fromMap(sqlConf))
+          .mergeWith(cliParameterTool)
 
         FlinkConfiguration(parameterTool, envConfig, tableConfig)
       }