From 378a7d030d9eb3ad660e35563a70ec36cc869fb9 Mon Sep 17 00:00:00 2001 From: benjobs Date: Sun, 15 Sep 2024 12:29:36 +0800 Subject: [PATCH] [Improve] program args bug fixed. --- .../org/apache/streampark/flink/core/FlinkTableInitializer.scala | 1 + 1 file changed, 1 insertion(+) 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) }