flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Nico <nico.franz...@gmail.com>
Subject AsyncFunction and Parallelism
Date Fri, 31 Mar 2017 10:17:53 GMT

I have a short question regarding the AsyncFunction of Flink 1.2.0. In the
documentation it says:

"[...] that the AsyncFunction is not called in a multi-threaded fashion.
There exists only one instance of the AsyncFunction and it is called
sequentially for each record in the respective partition of the stream."

Does it mean the there is only subtask of the Operator, so the parallelism
is always 1 for this Operator?

Thank you :)


View raw message