diff --git a/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkTableInitializer.scala b/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkTableInitializer.scala index 56267cbda7..fc2d073fcc 100644 --- a/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkTableInitializer.scala +++ b/streampark-flink/streampark-flink-shims/streampark-flink-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) }