Hi Anil, It is thread-safe. Each udf instance will only run in one task. And for each udf, it processes data synchronously, i.e, the next record will not be processed until the current record is processed.
Best, Hequn On Sat, Jan 12, 2019 at 3:12 AM Anil <anilsingh....@gmail.com> wrote: > Is the eval method invoked in a thread safe manner in Fink UDF. > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ >
