Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 5687420049B for ; Mon, 14 Aug 2017 12:35:50 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 54F72164DB2; Mon, 14 Aug 2017 10:35:50 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 759AA164DB3 for ; Mon, 14 Aug 2017 12:35:49 +0200 (CEST) Received: (qmail 32127 invoked by uid 500); 14 Aug 2017 10:35:47 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Delivered-To: mailing list user@flink.apache.org Received: (qmail 32107 invoked by uid 99); 14 Aug 2017 10:35:47 -0000 Received: from mail-relay.apache.org (HELO mail-relay.apache.org) (140.211.11.15) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 14 Aug 2017 10:35:47 +0000 Received: from aljoschas-mbp.fritz.box (ipservice-092-219-057-167.092.219.pools.vodafone-ip.de [92.219.57.167]) by mail-relay.apache.org (ASF Mail Server at mail-relay.apache.org) with ESMTPSA id 7884C1A0019; Mon, 14 Aug 2017 10:35:46 +0000 (UTC) From: Aljoscha Krettek Message-Id: <74A0B136-4DDC-4F92-B84D-F980FD363229@apache.org> Content-Type: multipart/alternative; boundary="Apple-Mail=_A6D03CC9-6189-4ED2-B748-E9F5FEC7F57D" Mime-Version: 1.0 (Mac OS X Mail 10.3 \(3273\)) Subject: Re: Queryable State max number of clients Date: Mon, 14 Aug 2017 12:35:44 +0200 In-Reply-To: Cc: user , Ufuk Celebi , Kostas Kloudas To: Ziyad Muhammed References: X-Mailer: Apple Mail (2.3273) archived-at: Mon, 14 Aug 2017 10:35:50 -0000 --Apple-Mail=_A6D03CC9-6189-4ED2-B748-E9F5FEC7F57D Content-Transfer-Encoding: quoted-printable Content-Type: text/plain; charset=us-ascii Hi, I think the number of network treads and number of query threads only = roughly correlate with the number of clients that can query in parallel = since this is using asynchronous communication via Akka/Netty. Of = course, increasing that number means there can be more connections but I = think even just 1 Thread or each of those should be able to easily = handle multiple queries at the same time. I'm cc'ing Ufuk and Kostas who might know more about this. Best, Aljoscha > On 9. Aug 2017, at 17:19, Ziyad Muhammed wrote: >=20 > Hi all, >=20 > I'm trying to understand how many parallel clients will be supported = by the queryable state.=20 >=20 > query.server.network-threads: number of network (event loop) threads = for the KvStateServer (0 =3D> #slots) > query.server.query-threads: number of asynchronous query threads for = the KvStateServerHandler (0 =3D> #slots). > so, if I choose 0 for both these parameters, what will be the maximum = number of parallel clients supported? >=20 > I tried more parallel clients than number of slots, but all of them = were able to query the state in parallel. Can someone help me to = understand the logic here? >=20 > Thanks in advance. >=20 > Best > Ziyad --Apple-Mail=_A6D03CC9-6189-4ED2-B748-E9F5FEC7F57D Content-Transfer-Encoding: quoted-printable Content-Type: text/html; charset=us-ascii Hi,

I = think the number of network treads and number of query threads only = roughly correlate with the number of clients that can query in parallel = since this is using asynchronous communication via Akka/Netty. Of = course, increasing that number means there can be more connections but I = think even just 1 Thread or each of those should be able to easily = handle multiple queries at the same time.

I'm cc'ing Ufuk and Kostas who might = know more about this.

Best,
Aljoscha

On = 9. Aug 2017, at 17:19, Ziyad Muhammed <mmziyad@gmail.com> = wrote:

Hi all,

I'm trying to understand how many = parallel clients will be supported by the queryable = state. 

  • query.server.network-threads: number of network (event = loop) threads for the KvStateServer (0 = =3D> #slots)
  • query.server.query-threads: number of asynchronous = query threads for the KvStateServerHandler (0 =3D> = #slots).
  • so, if I choose 0 for both these = parameters, what will be the maximum number of parallel clients = supported?

    I tried more parallel = clients than number of slots, but all of them were able to query the = state in parallel. Can someone help me to understand the logic = here?

    Thanks in advance.

    Best
    Ziyad

    = --Apple-Mail=_A6D03CC9-6189-4ED2-B748-E9F5FEC7F57D--