(incubator-streampark) branch prop created (now 16a4caa62)

[be...@apache.org]

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

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


      at 16a4caa62 [Improve] submit application dynamicProperties improvement

This branch includes the following new commits:

     new 16a4caa62 [Improve] submit application dynamicProperties improvement

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

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

[be...@apache.org]

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 <be...@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
       }