Re: Classloading issues with Flink Operator / Kubernetes Native

2022-09-21 Thread Javier Vegas
Version 1.15.2, there is no /opt/flink/usrlib folder created El mar, 20 sept 2022 a las 20:53, Yaroslav Tkachenko () escribió: > Interesting, do you see the /opt/flink/usrlib folder created as well? > Also, what Flink version do you use? > > Thanks. > > On Tue, Sep 20, 2022 at 4:04 PM Javier Vega

Re: Classloading issues with Flink Operator / Kubernetes Native

2022-09-20 Thread Yaroslav Tkachenko
Interesting, do you see the /opt/flink/usrlib folder created as well? Also, what Flink version do you use? Thanks. On Tue, Sep 20, 2022 at 4:04 PM Javier Vegas wrote: > > jarURI: local:///opt/flink/lib/MYJARNAME.jar > > El mar, 20 sept 2022 a las 0:25, Yaroslav Tkachenko () > escribió: > >> Hi

Re: Classloading issues with Flink Operator / Kubernetes Native

2022-09-20 Thread Javier Vegas
jarURI: local:///opt/flink/lib/MYJARNAME.jar El mar, 20 sept 2022 a las 0:25, Yaroslav Tkachenko () escribió: > Hi Javier, > > What do you specify as a jarURI? > > On Mon, Sep 19, 2022 at 3:56 PM Javier Vegas wrote: > >> I am doing the same thing (migrating from standalone to operator in >> nati

Re: Classloading issues with Flink Operator / Kubernetes Native

2022-09-20 Thread Yaroslav Tkachenko
Hi Javier, What do you specify as a jarURI? On Mon, Sep 19, 2022 at 3:56 PM Javier Vegas wrote: > I am doing the same thing (migrating from standalone to operator in native > mode) and also have my jar in /opt/flink/lib but for me it works fine, no > class loading errors on app startup. > > El

Re: Classloading issues with Flink Operator / Kubernetes Native

2022-09-19 Thread Javier Vegas
I am doing the same thing (migrating from standalone to operator in native mode) and also have my jar in /opt/flink/lib but for me it works fine, no class loading errors on app startup. El vie, 16 sept 2022 a las 9:28, Yaroslav Tkachenko () escribió: > Application mode. I've done a bit more resea

Re: Classloading issues with Flink Operator / Kubernetes Native

2022-09-16 Thread Yaroslav Tkachenko
Application mode. I've done a bit more research and created https://issues.apache.org/jira/browse/FLINK-29288, planning to work on a PR today. TLDR: currently Flink operator always creates /opt/flink/usrlib folder and forces you to specify the jarURI parameter, which is passed as pipeline.jars / p

Re: Classloading issues with Flink Operator / Kubernetes Native

2022-09-16 Thread Matthias Pohl via user
Are you deploying the job in session or application mode? Could you provide the stacktrace. I'm wondering whether that would be helpful to pin a code location for further investigation. So far, I couldn't come up with a definite answer about placing the jar in the lib directory. Initially, I would

Classloading issues with Flink Operator / Kubernetes Native

2022-09-12 Thread Yaroslav Tkachenko
Hey everyone, I’m migrating a Flink Kubernetes standalone job to the Flink operator (with Kubernetes native mode). I have a lot of classloading issues when trying to run with the operator in native mode. For example, I have a Postgres driver as a dependency (I can confirm the files are included i