youyangkou opened a new issue, #2184:
URL: https://github.com/apache/incubator-streampark/issues/2184

   ### Search before asking
   
   - [X] I had searched in the 
[issues](https://github.com/apache/incubator-streampark/issues?q=is%3Aissue+label%3A%22bug%22)
 and found no similar issues.
   
   
   ### What happened
   
   the regular expression bug of flink on k8s cluster-id Validation,should not 
be connected with _ or . instead of -
   
   ### StreamPark Version
   
   apache-2.0.0
   
   ### Java Version
   
   1.8
   
   ### Flink Version
   
   1.13.6
   
   ### Scala Version of Flink
   
   2.11
   
   ### Error Exception
   
   ```log
   java.util.concurrent.CompletionException: 
java.lang.reflect.InvocationTargetException
        at 
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:273)
        at 
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:280)
        at 
java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1592)
        at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
        at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        at java.lang.Thread.run(Thread.java:748)
   Caused by: java.lang.reflect.InvocationTargetException
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at 
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
        at 
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:498)
        at 
org.apache.streampark.flink.submit.FlinkSubmitter$$anonfun$submit$1.apply(FlinkSubmitter.scala:56)
        at 
org.apache.streampark.flink.submit.FlinkSubmitter$$anonfun$submit$1.apply(FlinkSubmitter.scala:51)
        at 
org.apache.streampark.flink.proxy.FlinkShimsProxy$$anonfun$proxy$1.apply(FlinkShimsProxy.scala:68)
        at 
org.apache.streampark.common.util.ClassLoaderUtils$.runAsClassLoader(ClassLoaderUtils.scala:39)
        at 
org.apache.streampark.flink.proxy.FlinkShimsProxy$.proxy(FlinkShimsProxy.scala:68)
        at 
org.apache.streampark.flink.submit.FlinkSubmitter$.submit(FlinkSubmitter.scala:51)
        at 
org.apache.streampark.flink.submit.FlinkSubmitter.submit(FlinkSubmitter.scala)
        at 
org.apache.streampark.console.core.service.impl.ApplicationServiceImpl.lambda$start$8(ApplicationServiceImpl.java:1477)
        at 
java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1590)
        ... 3 more
   Caused by: org.apache.flink.client.deployment.ClusterDeploymentException: 
Could not create Kubernetes cluster "flink_demo".
        at 
org.apache.flink.kubernetes.KubernetesClusterDescriptor.deployClusterInternal(KubernetesClusterDescriptor.java:289)
        at 
org.apache.flink.kubernetes.KubernetesClusterDescriptor.deployApplicationCluster(KubernetesClusterDescriptor.java:208)
        at 
org.apache.streampark.flink.submit.impl.KubernetesNativeApplicationSubmit$.doSubmit(KubernetesNativeApplicationSubmit.scala:70)
        at 
org.apache.streampark.flink.submit.trait.FlinkSubmitTrait$class.submit(FlinkSubmitTrait.scala:111)
        at 
org.apache.streampark.flink.submit.impl.KubernetesNativeApplicationSubmit$.submit(KubernetesNativeApplicationSubmit.scala:36)
        at 
org.apache.streampark.flink.submit.FlinkSubmit$.submit(FlinkSubmit.scala:34)
        at 
org.apache.streampark.flink.submit.FlinkSubmit.submit(FlinkSubmit.scala)
        ... 16 more
   Caused by: io.fabric8.kubernetes.client.KubernetesClientException: Failure 
executing: POST at: 
https://172.20.246.227:6443/apis/apps/v1/namespaces/flink-cluster/deployments. 
Message: Deployment.apps "flink_demo" is invalid: metadata.name: Invalid value: 
"flink_demo": a lowercase RFC 1123 subdomain must consist of lower case 
alphanumeric characters, '-' or '.', and must start and end with an 
alphanumeric character (e.g. 'example.com', regex used for validation is 
'[a-z0-9]([-a-z0-9]*[a-z0-9])?(\.[a-z0-9]([-a-z0-9]*[a-z0-9])?)*'). Received 
status: Status(apiVersion=v1, code=422, 
details=StatusDetails(causes=[StatusCause(field=metadata.name, message=Invalid 
value: "flink_demo": a lowercase RFC 1123 subdomain must consist of lower case 
alphanumeric characters, '-' or '.', and must start and end with an 
alphanumeric character (e.g. 'example.com', regex used for validation is 
'[a-z0-9]([-a-z0-9]*[a-z0-9])?(\.[a-z0-9]([-a-z0-9]*[a-z0-9])?)*'), 
reason=FieldValueInvalid, additionalProperti
 es={})], group=apps, kind=Deployment, name=flink_demo, retryAfterSeconds=null, 
uid=null, additionalProperties={}), kind=Status, message=Deployment.apps 
"flink_demo" is invalid: metadata.name: Invalid value: "flink_demo": a 
lowercase RFC 1123 subdomain must consist of lower case alphanumeric 
characters, '-' or '.', and must start and end with an alphanumeric character 
(e.g. 'example.com', regex used for validation is 
'[a-z0-9]([-a-z0-9]*[a-z0-9])?(\.[a-z0-9]([-a-z0-9]*[a-z0-9])?)*'), 
metadata=ListMeta(_continue=null, remainingItemCount=null, 
resourceVersion=null, selfLink=null, additionalProperties={}), reason=Invalid, 
status=Failure, additionalProperties={}).
        at 
io.fabric8.kubernetes.client.dsl.base.OperationSupport.requestFailure(OperationSupport.java:568)
        at 
io.fabric8.kubernetes.client.dsl.base.OperationSupport.assertResponseCode(OperationSupport.java:507)
        at 
io.fabric8.kubernetes.client.dsl.base.OperationSupport.handleResponse(OperationSupport.java:471)
        at 
io.fabric8.kubernetes.client.dsl.base.OperationSupport.handleResponse(OperationSupport.java:430)
        at 
io.fabric8.kubernetes.client.dsl.base.OperationSupport.handleCreate(OperationSupport.java:251)
        at 
io.fabric8.kubernetes.client.dsl.base.BaseOperation.handleCreate(BaseOperation.java:815)
        at 
io.fabric8.kubernetes.client.dsl.base.BaseOperation.create(BaseOperation.java:333)
        at 
org.apache.flink.kubernetes.kubeclient.Fabric8FlinkKubeClient.createJobManagerComponent(Fabric8FlinkKubeClient.java:109)
        at 
org.apache.flink.kubernetes.KubernetesClusterDescriptor.deployClusterInternal(KubernetesClusterDescriptor.java:274)
        ... 22 more
   ```
   
   
   ### Screenshots
   
   <img width="2222" alt="image" 
src="https://user-images.githubusercontent.com/33364356/208877534-1aa3507d-cfb5-47d8-bf9c-93430a62ba4f.png";>
   
   
   ### Are you willing to submit PR?
   
   - [X] Yes I am willing to submit a PR!
   
   ### Code of Conduct
   
   - [X] I agree to follow this project's [Code of 
Conduct](https://www.apache.org/foundation/policies/conduct)
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to