Hi,

Thanks Xintong.
I've noticed than when I use yarn-session.sh with --slots (-s) parameter but 
without --container (-n) it creates one task/slot per taskmanager. Before with 
the both n and -s it was not the case.
I prefer to use only small container with only one task to scale my pipeline 
and of course to prevent from thread-safe issue
Do you think I cannot be confident on that behaviour ?

Regards,
David

On 2020/02/22 17:11:25, 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
> 

Reply via email to