(incubator-streampark) branch dev-2.1.3 updated: [Improve] submit application dynamicProperties improvement (#3447)

[benjobs]

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

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


The following commit(s) were added to refs/heads/dev-2.1.3 by this push:
     new 324a8f6b1 [Improve] submit application dynamicProperties improvement 
(#3447)
324a8f6b1 is described below

commit 324a8f6b1fd55945d7c5869ca7cbc8dfff8648e4
Author: benjobs <benj...@apache.org>
AuthorDate: Tue Jan 2 19:05:14 2024 +0800

    [Improve] submit application dynamicProperties improvement (#3447)
    
    Co-authored-by: benjobs <benj...@gmail.com>
---
 .../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
       }