[incubator-streampark] branch dev updated: [Fix]fix pull flink base docker image end with space error. (#1904)

[be...@apache.org]

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 2ce6230be [Fix]fix pull flink base docker image end with space error. (#1904)
2ce6230be is described below

commit 2ce6230be86e839c1ae705d81da32cc3944bc4bc
Author: bitstring <we...@gmail.com>
AuthorDate: Wed Oct 26 12:05:55 2022 +0800

    [Fix]fix pull flink base docker image end with space error. (#1904)
    
    * [Fix]Update flink base docker image tag trim space.
    
    Signed-off-by: Wyatt Jia <i...@eventloop.live>
---
 .../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 3751aa1dd..b3f585941 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
@@ -120,7 +120,7 @@ class FlinkK8sApplicationBuildPipeline(request: FlinkK8sApplicationBuildRequest)
       }.getOrElse(throw getError.exception)
 
     val dockerConf = request.dockerConfig
-    val baseImageTag = request.flinkBaseImage
+    val baseImageTag = request.flinkBaseImage.trim
     val pushImageTag = {
       val expectedImageTag = s"streamparkflinkjob-${request.k8sNamespace}-${request.clusterId}"
       compileTag(expectedImageTag, dockerConf.registerAddress, dockerConf.imageNamespace)