Hi, To expand a bit on that, each function is only invoked by one Thread concurrently but the function might be serialised and sent to several executors (TaskManagers) for parallel execution. For more information, check out [1] and [2].
Best, Aljoscha [1] https://ci.apache.org/projects/flink/flink-docs-release-1.3/concepts/programming-model.html <https://ci.apache.org/projects/flink/flink-docs-release-1.3/concepts/programming-model.html> [2] https://ci.apache.org/projects/flink/flink-docs-release-1.3/concepts/runtime.html <https://ci.apache.org/projects/flink/flink-docs-release-1.3/concepts/runtime.html> > On 26. May 2017, at 17:21, Kostas Kloudas <k.klou...@data-artisans.com> wrote: > > Your objects will be processed by a single thread. > > Kostas > >> On May 26, 2017, at 4:50 PM, luutuan <tluud...@bol.com> wrote: >> >> Hi, when I have a set of objects goes through a RichFilterFunction, by >> default, will the filter handle all objects in 1 single thread or will >> divide the work to multiple threads? >> Thank you. >> >> >> >> -- >> View this message in context: >> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Does-RichFilterFunction-work-on-multiple-thread-tp13346.html >> Sent from the Apache Flink User Mailing List archive. mailing list archive >> at Nabble.com. >
