Hello,

I am currently testing a scenario where I would run the same job multiple times 
in a loop with different inputs each time. I am testing with a local Flink 
cluster v1.12.4. I initially got an OOM - Metaspace error, so I increased the 
corresponding memory in the TM's JVM (to 512m), but it still fails sometimes.

I found this issue that talked about Python jobs: 
https://issues.apache.org/jira/browse/FLINK-20333, but there is a comment there 
saying that it would also affect Java jobs. The commit linked there seems to be 
concerned with Python only. Was this also fixed in 1.12.0 for Java?

Is there anything I could do to force a more thorough class loader cleanup 
after each call to execute() ?

Regards,
Alexis.


Reply via email to