Re: Does RichFilterFunction work on multiple thread?

Posted by Aljoscha Krettek on May 29, 2017; 12:42pm
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Does-RichFilterFunction-work-on-multiple-thread-tp13346p13365.html

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

[2] https://ci.apache.org/projects/flink/flink-docs-release-1.3/concepts/runtime.html

On 26. May 2017, at 17:21, Kostas Kloudas <[hidden email]> wrote:

Your objects will be processed by a single thread.

Kostas

On May 26, 2017, at 4:50 PM, luutuan <[hidden email]> 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.