(incubator-streampark) 01/01: [Improve] submit application dynamicProperties improvement

[benjobs]

This is an automated email from the ASF dual-hosted git repository.

benjobs pushed a commit to branch prop
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git

commit 16a4caa62d759bf4e19bf8b28cade7653b2ae5f7
Author: benjobs <benj...@gmail.com>
AuthorDate: Tue Jan 2 19:04:16 2024 +0800

    [Improve] submit application dynamicProperties improvement
---
 .../apache/streampark/flink/client/trait/FlinkClientTrait.scala   | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git 
a/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/FlinkClientTrait.scala
 
b/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/FlinkClientTrait.scala
index 4e3d5adcd..0ef862883 100644
--- 
a/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/FlinkClientTrait.scala
+++ 
b/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/FlinkClientTrait.scala
@@ -353,11 +353,11 @@ trait FlinkClientTrait extends Logger {
         submitRequest.properties.foreach {
           key =>
             if (!key._1.startsWith(CoreOptions.FLINK_JVM_OPTIONS.key())) {
+              logInfo(s"submit application dynamicProperties:  ${key._1} 
:${key._2}")
               array += s"-D${key._1}=${key._2}"
             }
         }
       }
-
       array.toArray
     }
 
@@ -396,7 +396,11 @@ trait FlinkClientTrait extends Logger {
         val array = new ArrayBuffer[String]()
         // The priority of the parameters defined on the page is greater than 
the app conf file, property parameters etc.
         if (MapUtils.isNotEmpty(properties)) {
-          properties.foreach(x => array += s"-D${x._1}=${x._2.toString.trim}")
+          properties.foreach(
+            x => {
+              array += s"-D${x._1}=${x._2.toString.trim}"
+              logInfo(s"deploy cluster dynamicProperties:  ${x._1} :${x._2}")
+            })
         }
         array.toArray
       }