You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I had searched with the issues and found no similar issues.
What happened
when I started a flink job in kubernetes-applicatin mode, it had shown the problem which was 'ERROR | ForkJoinPool-2-worker-2 | org.apache.streampark.flink.kubernetes.KubernetesRetriever:71] [StreamPark] Get flinkClient error, the error is: java.lang.RuntimeException: org.apache.flink.client.deployment.ClusterRetrieveException: Could not create the RestClusterClient.' .
Rest-Service Exposed Type : ClusterIP
The task status is always 'INITIALIZING'
Actually, The flink Cluster had been created successfully in on k8s
StreamPark Version
dev-2.0.0
Java Version
1.8.0_181
Flink Version
1.14.3
Scala Version of Flink
2.12
Error Exception
Refer the 'What happened' module.
Screenshots
however, when I choose the 'NodePort', the same task could be started successfully as following:
The text was updated successfully, but these errors were encountered:
green241
changed the title
[Bug] [StreamPark] Get flinkClient error, the error is: java.lang.RuntimeException: org.apache.flink.client.deployment.ClusterRetrieveException: Could not create the RestClusterClient.
[Bug] when choose the Rest-Service Exposed Type with the value of 'ClusterIP' , the job status could not show correctlly.
Dec 27, 2022
Search before asking
What happened
when I started a flink job in kubernetes-applicatin mode, it had shown the problem which was 'ERROR | ForkJoinPool-2-worker-2 | org.apache.streampark.flink.kubernetes.KubernetesRetriever:71] [StreamPark] Get flinkClient error, the error is: java.lang.RuntimeException: org.apache.flink.client.deployment.ClusterRetrieveException: Could not create the RestClusterClient.' .
Rest-Service Exposed Type : ClusterIP
The task status is always 'INITIALIZING'
Actually, The flink Cluster had been created successfully in on k8s
StreamPark Version
dev-2.0.0
Java Version
1.8.0_181
Flink Version
1.14.3
Scala Version of Flink
2.12
Error Exception
Screenshots
however, when I choose the 'NodePort', the same task could be started successfully as following:
Are you willing to submit PR?
Code of Conduct
The text was updated successfully, but these errors were encountered: