You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampark.apache.org by be...@apache.org on 2023/04/12 05:05:36 UTC
[incubator-streampark] branch dev updated: [bug] there is no log output in kubernetes session cluster (#2599)
This is an automated email from the ASF dual-hosted git repository.
benjobs 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 721a88f89 [bug] there is no log output in kubernetes session cluster (#2599)
721a88f89 is described below
commit 721a88f89dd07e6502285616a21645030125f638
Author: zhoulii <zh...@foxmail.com>
AuthorDate: Wed Apr 12 13:05:30 2023 +0800
[bug] there is no log output in kubernetes session cluster (#2599)
Co-authored-by: zhoulii <zh...@hikvision.com.cn>
---
.../streampark/flink/client/impl/KubernetesNativeSessionClient.scala | 1 +
1 file changed, 1 insertion(+)
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 60150d402..fb429d94e 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
@@ -149,6 +149,7 @@ object KubernetesNativeSessionClient extends KubernetesNativeClientTrait with Lo
.safeSet(KubernetesConfigOptions.CLUSTER_ID, deployRequest.clusterId)
.safeSet(KubernetesConfigOptions.CONTAINER_IMAGE, deployRequest.k8sDeployParam.flinkImage)
.safeSet(KubernetesConfigOptions.KUBE_CONFIG_FILE, getDefaultKubernetesConf(deployRequest.k8sDeployParam.kubeConf))
+ .safeSet(DeploymentOptionsInternal.CONF_DIR, s"${deployRequest.flinkVersion.flinkHome}/conf")
val kubernetesClusterDescriptor = getK8sClusterDescriptorAndSpecification(flinkConfig)
clusterDescriptor = kubernetesClusterDescriptor._1