I'm taking a look at: - https://issues.apache.org/jira/browse/FLINK-28171 which might be related although it considers Istio instead of Linkerd.
In general it would be nice to have some general guidance on how to setup/deploy flink jobs to k8s in presence of a service mesh. Regards, Salva On 2023/01/09 15:07:51 Salva Alcántara wrote: > I've been deploying a job without issues until injecting the linkerd proxy > in order to access some services under a service mesh. In particular, I'm > receiving the following error on the job manager side: > > ``` > java.lang.ClassNotFoundException: a.class.of.Mine > ``` > > On the taskamanager side, it cannot join the cluster based on the following > error: > ``` > Could not find any IPv4 address that is not loopback or link-local. Using > localhost address > ``` > > That is weird and I'm assuming a problem with the setup of linkerd since > the jar actually contains the the reported class (`a.class.of.Mine`). In > order to provide some more context, the job is deployed to k8s via the VVP > (version 2.7.1 for what it's worth). > > Regarding the jobmanager/taskmanager templates, I'm using the following pod > annotations: > > ``` > linkerd.io/inject: enabled > config.linkerd.io/skip-outbound-ports: 8125,8126 # for metrics > config.linkerd.io/proxy-await: enabled > ``` > > PS: Also posted in SO: > - > https://stackoverflow.com/questions/75059165/classnotdeffouncexception-when-deploying-flink-in-k8s-using-linkerd >
