Fix the check for the PVC's namespaces

core/cloudflow-cli/src/main/scala/akka/cli/cloudflow/execution/ConfigureExecution.scala

@@ -30,7 +30,7 @@ final case class ConfigureExecution(c: Configure, client: KubeClient, logger: Cl
         c.aggregatedConfig,
         currentCr,
         logbackContent,
-        () => client.getPvcs(namespace = currentCr.spec.appId))
+        () => client.getPvcs(namespace = namespace))
 
       // streamlets configurations
       streamletsConfigs <- streamletsConfigs(

core/cloudflow-cli/src/main/scala/akka/cli/cloudflow/execution/DeployExecution.scala

@@ -172,7 +172,7 @@ final case class DeployExecution(d: Deploy, client: KubeClient, logger: CliLogge
       applicationCr <- updateVolumeMounts(
         applicationCrReplicas,
         d.volumeMounts,
-        () => client.getPvcs(namespace = applicationCrReplicas.spec.appId))
+        () => client.getPvcs(namespace = namespace))
 
       image <- getImageReference(applicationCr)
 
@@ -182,7 +182,7 @@ final case class DeployExecution(d: Deploy, client: KubeClient, logger: CliLogge
         d.aggregatedConfig,
         applicationCr,
         logbackContent,
-        () => client.getPvcs(namespace = applicationCr.spec.appId))
+        () => client.getPvcs(namespace = namespace))
 
       // validation of the CR
       _ <- applicationDescriptorValidation(applicationCr)
@@ -196,7 +196,7 @@ final case class DeployExecution(d: Deploy, client: KubeClient, logger: CliLogge
       // validate the Cr against the cluster
       _ <- referencedKafkaSecretExists(
         applicationCr,
-        () => client.getKafkaClusters(namespace = Some(applicationCr.spec.appId)).map(_.keys.toList))
+        () => client.getKafkaClusters(namespace = Some(namespace)).map(_.keys.toList))
 
       // streamlets configurations
       streamletsConfigs <- streamletsConfigs(applicationCr, cloudflowConfig, d.microservices, () => {