flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Kostas Kloudas <k.klou...@data-artisans.com>
Subject Re: AsyncFunction and Parallelism
Date Fri, 31 Mar 2017 10:23:03 GMT
Hi Nico,

No, you can have as many parallel tasks doing async IO operations as you want.
What the documentation says is that in each one of these tasks, there is one thread handling

the requests.

Hope this helps,
Kostas 

> On Mar 31, 2017, at 12:17 PM, Nico <nico.franzeck@gmail.com> wrote:
> 
> Hi,
> 
> 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 :)
> 
> Best,
> Nico


Mime
View raw message