Hi all I m trying to run the native kubernetes example but f Apache Flink #troubleshooting

Hi all, I'm trying to run the native kubernetes ex...

Sergio Morales

01/18/2023, 3:52 PM

Hi all, I'm trying to run the native kubernetes example but fails with:

io.fabric8.kubernetes.client.KubernetesClientException: JcaPEMKeyConverter is provided by BouncyCastle

. I added the 1.70 version for both libraries: https://mvnrepository.com/artifact/org.bouncycastle/bcprov-jdk15on, https://mvnrepository.com/artifact/org.bouncycastle/bcpkix-jdk15on but now when running the command to run flink in kubernetes (

./bin/kubernetes-session.sh -Dkubernetes.cluster-id=my-first-flink-cluster

) it does not startup the jobmanager. Any ideas?

Sergio Morales

01/18/2023, 3:53 PM

The logs in Kubernetes say:

MountVolume.SetUp failed for volume "flink-config-volume" : configmap "flink-config-my-first-flink-cluster" not found

Sergio Morales

01/18/2023, 3:58 PM

Ok after retrying that is fixed, but now the container keeps being restarted:

Copy code

terminated
Reason:Reason: Error - exit code: 239
Started at: 2023-01-18T16:57:05+01:00
Finished at: 2023-01-18T16:57:29+01:00

Sergio Morales

01/18/2023, 4:07 PM

Ok, seems to be permissions (?):

Copy code

Caused by: io.fabric8.kubernetes.client.KubernetesClientException: Failure executing: GET at: <https://10.43.0.1/api/v1/namespaces/default/pods?labelSelector=app%3Dmy-first-flink-cluster%2Ccomponent%3Dtaskmanager%2Ctype%3Dflink-native-kubernetes&allowWatchBookmarks=true&watch=true>. Message: Forbidden.

Sergio Morales

01/18/2023, 4:12 PM

yep, it was permissions. With this it worked:

Copy code

$ kubectl create clusterrolebinding flink-role-binding-default --clusterrole=edit --serviceaccount=default:default

Open in Slack

Previous Next