jarURI: local:///opt/flink/lib/MYJARNAME.jar

El mar, 20 sept 2022 a las 0:25, Yaroslav Tkachenko (<yaros...@goldsky.com>)
escribió:

> Hi Javier,
>
> What do you specify as a jarURI?
>
> On Mon, Sep 19, 2022 at 3:56 PM Javier Vegas <jve...@strava.com> 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 vie, 16 sept 2022 a las 9:28, Yaroslav Tkachenko (<
>> yaros...@goldsky.com>) escribió:
>>
>>> 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 / pipeline.classpaths configuration options. This leads to
>>> the jar being loaded twice by different classloaders (system and user
>>> ones).
>>>
>>> On Fri, Sep 16, 2022 at 2:30 AM Matthias Pohl <matthias.p...@aiven.io>
>>> wrote:
>>>
>>>> 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 have thought that it's fine
>>>> considering that all dependencies are included and the job jar itself ends
>>>> up on the user classpath. I'm curious whether Chesnay (CC'd) has an answer
>>>> to that one.
>>>>
>>>> On Tue, Sep 13, 2022 at 1:40 AM Yaroslav Tkachenko <
>>>> yaros...@goldsky.com> wrote:
>>>>
>>>>> 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 in the uber jar), but I
>>>>> still get "java.sql.SQLException: No suitable driver found for
>>>>> jdbc:postgresql:..." exception.
>>>>>
>>>>> In the Kubernetes standalone setup my uber jar is placed in the
>>>>> /opt/flink/lib folder, this is what I specify as "jarURI" in the operator
>>>>> config. Is this supported? Should I only be using /opt/flink/usrlib?
>>>>>
>>>>> Thanks for any suggestions.
>>>>>
>>>>

Reply via email to