now if
> it will resolve my oom metaspace problem
>
> Get Outlook for iOS <https://aka.ms/o0ukef>
> --
> *From:* David Morávek
> *Sent:* Tuesday, December 21, 2021 5:59:05 PM
> *To:* Lior Liviev ; user
> *Subject:* Re: Class loader
>
>
>
> if I have my user code Jar in Flink
>
I assume this means that the user code is already on Flink's class path
(eg. /lib folder).
Then it depends on how the class-loader is set up [1] and on how you submit
the job. For session cluster, each job is isolated in a separate
clas
I assume this is a duplicate of the previous thread [1]
[1] https://lists.apache.org/thread/16kxytrqycolfwfmr5tv0g6bq9m2wvof
Best,
D.
On Tue, Dec 21, 2021 at 3:53 PM Lior Liviev wrote:
> Hello, I wanted to know if I have my user code Jar in Flink, and I'm
> running it 3 times, wil
Hello, I wanted to know if I have my user code Jar in Flink, and I'm running it
3 times, will the class loader take the same classes at every execution?
2:51 AM Vishwas Siravara
> wrote:
>
>> I have a standalone cluster. I have added my own library(jar file) to the
>> lib/ folder in flink . I submit my job from cli after I start the cluster.
>> Now I want to externalize a property file which has to be read by this
>> libr
ary. Since this library is loaded by flink's classloader and not the
> application class loader I cannot supply this using flink run -C ... since
> this works only for user class loader.
>
>
> Thanks,
> Vishwas
>
t the
application class loader I cannot supply this using flink run -C ... since
this works only for user class loader.
Thanks,
Vishwas
re is a job failure
>> and restart (in our case from checkpoint timeout), it begins a failure loop
>> that requires a cancellation and resubmission to fix. The expected and
>> desired outcome should be a recovery from failure and the job restarts
>> successfully. Some dig
ssion to fix. The expected and
> desired outcome should be a recovery from failure and the job restarts
> successfully. Some digging revealed an issue where the class loader closes
> before the connection to kafka is fully terminated resulting in a
> NoClassDefFoundError. A description of what
. The expected and desired outcome should
be a recovery from failure and the job restarts successfully. Some digging
revealed an issue where the class loader closes before the connection to kafka
is fully terminated resulting in a NoClassDefFoundError. A description of what
is happening has already
Hi Jared,
I currently don't have a solid idea of what may be happening, but from the
stack dump you provided, it seems like the client connection you are using
in the Elasticsearch API call bridge is stuck, even after the cleanup.
Do you think there could be some issue with closing the client you
dThread.run(ClientCnxn.java:1141)
>
> Locked ownable synchronizers:
> - None
>
> --
> Jared Stehler
> Chief Architect - Intellify Learning
> o: 617.701.6330 x703
>
>
>
>> On Jan 11, 2018, at 10:07 AM, Jared Stehler
>> > <mailto:jare
adic issues where it appears that curator (or other) user
> threads are left running after a stream shutdown, and then the user class
> loader goes away and I get spammed with ClassNotFoundExceptions… I’m
> wondering if this might have something to do with perhaps the UserClassLoader
&
I’m seeing sporadic issues where it appears that curator (or other) user
threads are left running after a stream shutdown, and then the user class
loader goes away and I get spammed with ClassNotFoundExceptions… I’m wondering
if this might have something to do with perhaps the UserClassLoader
14 matches
Mail list logo
