Mailing-List: contact user-help@flink.apache.org; run by ezmlm
Precedence: bulk
From: Kostas Kloudas <k.kloudas@data-artisans.com>
Message-Id: <C511AF67-ACF6-4046-8D88-D433DE09D59A@data-artisans.com>
Content-Type: multipart/alternative;
 boundary="Apple-Mail=_B674C2B6-D5A9-4C9A-B0D4-2CBEFE8F8CC1"
Mime-Version: 1.0 (Mac OS X Mail 10.2 \(3259\))
Subject: Re: AsyncFunction and Parallelism
Date: Fri, 31 Mar 2017 12:23:03 +0200
In-Reply-To: <CAHwcdKuZnK88PyoyZ=Px1sr_N=UTh_t+LyJt16f4XYDCQeGsvQ@mail.gmail.com>
Cc: user@flink.apache.org
To: Nico <nico.franzeck@gmail.com>
References: <CAHwcdKuZnK88PyoyZ=Px1sr_N=UTh_t+LyJt16f4XYDCQeGsvQ@mail.gmail.com>
archived-at: Fri, 31 Mar 2017 10:23:11 -0000


--Apple-Mail=_B674C2B6-D5A9-4C9A-B0D4-2CBEFE8F8CC1
Content-Transfer-Encoding: quoted-printable
Content-Type: text/plain;
	charset=us-ascii

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=20
the requests.

Hope this helps,
Kostas=20

> On Mar 31, 2017, at 12:17 PM, Nico <nico.franzeck@gmail.com> wrote:
>=20
> Hi,
>=20
> I have a short question regarding the AsyncFunction of Flink 1.2.0. In =
the documentation it says:
>=20
> "[...] 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."
>=20
> Does it mean the there is only subtask of the Operator, so the =
parallelism is always 1 for this Operator?=20
>=20
> Thank you :)
>=20
> Best,
> Nico


--Apple-Mail=_B674C2B6-D5A9-4C9A-B0D4-2CBEFE8F8CC1
Content-Transfer-Encoding: quoted-printable
Content-Type: text/html;
	charset=us-ascii

<html><head><meta http-equiv=3D"Content-Type" content=3D"text/html =
charset=3Dus-ascii"></head><body style=3D"word-wrap: break-word; =
-webkit-nbsp-mode: space; -webkit-line-break: after-white-space;" =
class=3D"">Hi Nico,<div class=3D""><br class=3D""></div><div =
class=3D"">No, you can have as many parallel tasks doing async IO =
operations as you want.</div><div class=3D"">What the documentation says =
is that in each one of these tasks, there is one thread =
handling&nbsp;</div><div class=3D"">the requests.</div><div class=3D""><br=
 class=3D""></div><div class=3D"">Hope this helps,</div><div =
class=3D"">Kostas&nbsp;</div><div class=3D""><br =
class=3D""><div><blockquote type=3D"cite" class=3D""><div class=3D"">On =
Mar 31, 2017, at 12:17 PM, Nico &lt;<a =
href=3D"mailto:nico.franzeck@gmail.com" =
class=3D"">nico.franzeck@gmail.com</a>&gt; wrote:</div><br =
class=3D"Apple-interchange-newline"><div class=3D""><div dir=3D"ltr" =
class=3D""><div class=3D""><div class=3D""><div class=3D""><div =
class=3D""><div class=3D"">Hi,<br class=3D""><br class=3D""></div>I have =
a short question regarding the AsyncFunction of Flink 1.2.0. In the =
documentation it says:<br class=3D""><br class=3D"">"[...] that the =
<code class=3D"">AsyncFunction</code> is not called in a multi-threaded =
fashion.
There exists only one instance of the <code =
class=3D"">AsyncFunction</code> and it is called sequentially for each =
record in the respective partition
of the stream."<br class=3D""><br class=3D""></div>Does it mean the =
there is only subtask of the Operator, so the parallelism is always 1 =
for this Operator? <br class=3D""><br class=3D""></div>Thank you :)<br =
class=3D""><br class=3D""></div>Best,<br class=3D""></div>Nico<br =
class=3D""> </div>
</div></blockquote></div><br class=3D""></div></body></html>=

--Apple-Mail=_B674C2B6-D5A9-4C9A-B0D4-2CBEFE8F8CC1--