[Imporve] Request.namesapce and request.clusterId dont't allow to be …

…empty
apache · Jun 19, 2024 · fb7a02f · fb7a02f
1 parent 2d5e002
commit fb7a02f
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...a/org/apache/streampark/flink/packer/pipeline/impl/FlinkK8sApplicationBuildPipeline.scala b/...a/org/apache/streampark/flink/packer/pipeline/impl/FlinkK8sApplicationBuildPipeline.scala
@@ -127,6 +127,9 @@ class FlinkK8sApplicationBuildPipeline(request: FlinkK8sApplicationBuildRequest)
     val dockerConf = request.dockerConfig
     val baseImageTag = request.flinkBaseImage.trim
     val pushImageTag = {
+      if (request.k8sNamespace.isEmpty || request.clusterId.isEmpty) {
+        throw new IllegalArgumentException("k8sNamespace and clusterId cannot be empty")
+      }
       val expectedImageTag = s"streampark-flinkjob-${request.k8sNamespace}-${request.clusterId}"
       compileTag(expectedImageTag, dockerConf.registerAddress, dockerConf.imageNamespace)
     }