Re: Official Flink operator additional class paths

2022-04-07 Thread Francis Conroy
Hi Yang, thanks a lot for your help. It ended up being the case that my command in the initContainer was specified incorrectly. On Thu, 7 Apr 2022 at 18:41, Yang Wang wrote: > It seems that you have a typo when specifying the pipeline classpath. > "file:///flink-jar/flink-connector-rabbitmq_2.

Re: Official Flink operator additional class paths

2022-04-07 Thread Yang Wang
It seems that you have a typo when specifying the pipeline classpath. "file:///flink-jar/flink-connector-rabbitmq_2.12-1.14.4.jar" -> "file:///flink-jars/flink-connector-rabbitmq_2.12-1.14.4.jar" If this is not the root cause, maybe you could have a try with downloading the connector jars to /opt/

Official Flink operator additional class paths

2022-04-07 Thread Francis Conroy
Hi all, thanks in advance for any tips. I've been trying to specify some additional classpaths in my kubernetes yaml file when using the official flink operator and nothing seems to work. I know the technique for getting my job jar works fine since it's finding the class ok, but I cannot get the