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 ec4ea9e0a [Improve] log info minor improvement
ec4ea9e0a is described below

commit ec4ea9e0a66e68e5bdd2efe4f00d78d69f35217f
Author: benjobs <[email protected]>
AuthorDate: Wed Jan 31 08:53:32 2024 +0800

    [Improve] log info minor improvement
---
 .../streampark/console/core/service/impl/FlinkClusterServiceImpl.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkClusterServiceImpl.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkClusterServiceImpl.java
index cc04a5f5d..88690f50e 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkClusterServiceImpl.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkClusterServiceImpl.java
@@ -169,7 +169,7 @@ public class FlinkClusterServiceImpl extends 
ServiceImpl<FlinkClusterMapper, Fli
     try {
       // 1) deployRequest
       DeployRequest deployRequest = getDeployRequest(flinkCluster);
-      log.info("deploy cluster request: " + deployRequest);
+      log.info("deploy cluster request: {}", deployRequest);
 
       Future<DeployResponse> future =
           executorService.submit(() -> FlinkClient.deploy(deployRequest));

Reply via email to