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)
}