This is an automated email from the ASF dual-hosted git repository.
panyuepeng pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
The following commit(s) were added to refs/heads/dev by this push:
new e33e185a7 [Improve] Change describing ambiguous logs and printing logs
(#3235)
e33e185a7 is described below
commit e33e185a74073ee6a5a84fe374738d9d8deec624
Author: caicancai <[email protected]>
AuthorDate: Thu Oct 12 11:40:11 2023 +0800
[Improve] Change describing ambiguous logs and printing logs (#3235)
---
.../flink/client/impl/KubernetesNativeSessionClient.scala | 6 +++---
.../streampark/flink/client/impl/KubernetesSessionClientV2.scala | 6 +++---
2 files changed, 6 insertions(+), 6 deletions(-)
diff --git
a/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/KubernetesNativeSessionClient.scala
b/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/KubernetesNativeSessionClient.scala
index 0ae093f0d..0a7e9c11e 100644
---
a/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/KubernetesNativeSessionClient.scala
+++
b/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/KubernetesNativeSessionClient.scala
@@ -131,7 +131,7 @@ object KubernetesNativeSessionClient extends
KubernetesNativeClientTrait with Lo
def deploy(deployRequest: DeployRequest): DeployResponse = {
logInfo(
s"""
- |--------------------------------------- kubernetes session start
---------------------------------------
+ |--------------------------------------- kubernetes cluster start
---------------------------------------
| userFlinkHome : ${deployRequest.flinkVersion.flinkHome}
| flinkVersion : ${deployRequest.flinkVersion.version}
| execMode : ${deployRequest.executionMode.name()}
@@ -140,8 +140,8 @@ object KubernetesNativeSessionClient extends
KubernetesNativeClientTrait with Lo
| exposedType :
${deployRequest.k8sDeployParam.flinkRestExposedType}
| serviceAccount : ${deployRequest.k8sDeployParam.serviceAccount}
| flinkImage : ${deployRequest.k8sDeployParam.flinkImage}
- | properties : ${deployRequest.properties.mkString(" ")}
-
|-------------------------------------------------------------------------------------------
+ | properties : ${deployRequest.properties.mkString(",")}
+
|--------------------------------------------------------------------------------------------------------
|""".stripMargin)
var clusterDescriptor: KubernetesClusterDescriptor = null
var client: ClusterClient[String] = null
diff --git
a/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/KubernetesSessionClientV2.scala
b/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/KubernetesSessionClientV2.scala
index de4dbe6cf..214d6c15a 100644
---
a/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/KubernetesSessionClientV2.scala
+++
b/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/KubernetesSessionClientV2.scala
@@ -128,7 +128,7 @@ object KubernetesSessionClientV2 extends
KubernetesClientV2Trait with Logger {
def deploy(deployRequest: DeployRequest): DeployResponse = {
logInfo(
s"""
- |--------------------------------------- kubernetes session start
---------------------------------------
+ |--------------------------------------- kubernetes cluster start
---------------------------------------
| userFlinkHome : ${deployRequest.flinkVersion.flinkHome}
| flinkVersion : ${deployRequest.flinkVersion.version}
| execMode : ${deployRequest.executionMode.name()}
@@ -137,8 +137,8 @@ object KubernetesSessionClientV2 extends
KubernetesClientV2Trait with Logger {
| exposedType :
${deployRequest.k8sDeployParam.flinkRestExposedType}
| serviceAccount : ${deployRequest.k8sDeployParam.serviceAccount}
| flinkImage : ${deployRequest.k8sDeployParam.flinkImage}
- | properties : ${deployRequest.properties.mkString(" ")}
-
|-------------------------------------------------------------------------------------------
+ | properties : ${deployRequest.properties.mkString(",")}
+
|--------------------------------------------------------------------------------------------------------
|""".stripMargin)
val richMsg: String => String =
s"[flink-submit][appId=${deployRequest.id}] " + _
