You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampark.apache.org by pa...@apache.org on 2023/10/12 03:40:17 UTC
[incubator-streampark] branch dev updated: [Improve] Change describing ambiguous logs and printing logs (#3235)
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 <77...@users.noreply.github.com>
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}] " + _