Hi David, In general, I don't think you can control all parallel subtasks of a certain task run in the same JVM process with the current Flink.
If you job scale is very small, one thing you might try is to have only one task manager in the Flink session cluster. You need to make sure the task manager has enough cpu/memory resources and slots for running your job. Thank you~ Xintong Song On Sun, Feb 23, 2020 at 1:11 AM David Morin <morin.david....@gmail.com> wrote: > Hi, > My app is based on a lib that is not thread safe (yet...). > In waiting of the patch has been pushed, how can I be sure that my Sink > that uses this lib is in one JVM ? > Context: I use one Yarn session and send my Flink jobs to this session > > Regards, > David >
