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));