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 ff3274ed6 [Bug]Docker image tag contains space character (#3708)
ff3274ed6 is described below

commit ff3274ed697c858a4e12408e00fb40861f5f016d
Author: yaolei <[email protected]>
AuthorDate: Tue May 14 19:09:49 2024 +0800

    [Bug]Docker image tag contains space character (#3708)
---
 .../flink/packer/pipeline/impl/FlinkK8sApplicationBuildPipeline.scala   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/pipeline/impl/FlinkK8sApplicationBuildPipeline.scala
 
b/streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/pipeline/impl/FlinkK8sApplicationBuildPipeline.scala
index 25849fa32..8117b94a6 100644
--- 
a/streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/pipeline/impl/FlinkK8sApplicationBuildPipeline.scala
+++ 
b/streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/pipeline/impl/FlinkK8sApplicationBuildPipeline.scala
@@ -127,7 +127,7 @@ class FlinkK8sApplicationBuildPipeline(request: 
FlinkK8sApplicationBuildRequest)
     val dockerConf = request.dockerConfig
     val baseImageTag = request.flinkBaseImage.trim
     val pushImageTag = {
-      val expectedImageTag = s"streampark 
flinkjob-${request.k8sNamespace}-${request.clusterId}"
+      val expectedImageTag = 
s"streampark-flinkjob-${request.k8sNamespace}-${request.clusterId}"
       compileTag(expectedImageTag, dockerConf.registerAddress, 
dockerConf.imageNamespace)
     }
 

Reply via email to