Return-Path: X-Original-To: apmail-storm-user-archive@minotaur.apache.org Delivered-To: apmail-storm-user-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id B29FF18920 for ; Sat, 13 Feb 2016 16:47:21 +0000 (UTC) Received: (qmail 52508 invoked by uid 500); 13 Feb 2016 16:47:20 -0000 Delivered-To: apmail-storm-user-archive@storm.apache.org Received: (qmail 52458 invoked by uid 500); 13 Feb 2016 16:47:20 -0000 Mailing-List: contact user-help@storm.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@storm.apache.org Delivered-To: mailing list user@storm.apache.org Received: (qmail 52449 invoked by uid 99); 13 Feb 2016 16:47:20 -0000 Received: from Unknown (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Sat, 13 Feb 2016 16:47:20 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id D8E3C1A036F for ; Sat, 13 Feb 2016 16:47:19 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -1.3 X-Spam-Level: X-Spam-Status: No, score=-1.3 tagged_above=-999 required=6.31 tests=[KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_DNSWL_MED=-2.3] autolearn=disabled Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id fQSyWHpszCYy for ; Sat, 13 Feb 2016 16:47:18 +0000 (UTC) Received: from mx2.mailbox.org (mx2.mailbox.org [80.241.60.215]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTPS id CB8695FAF2 for ; Sat, 13 Feb 2016 16:47:17 +0000 (UTC) Received: from smtp1.mailbox.org (smtp1.mailbox.org [80.241.60.240]) (using TLSv1.2 with cipher ECDHE-RSA-AES256-GCM-SHA384 (256/256 bits)) (No client certificate requested) by mx2.mailbox.org (Postfix) with ESMTPS id 02EB641F82 for ; Sat, 13 Feb 2016 17:47:09 +0100 (CET) X-Virus-Scanned: amavisd-new at heinlein-support.de Received: from smtp1.mailbox.org ([80.241.60.240]) by hefe.heinlein-support.de (hefe.heinlein-support.de [91.198.250.172]) (amavisd-new, port 10030) with ESMTP id DHtWDzjNx99P for ; Sat, 13 Feb 2016 17:47:09 +0100 (CET) Subject: Re: Need Help regarding topology with numWorker>1 To: user@storm.apache.org References: <56BCE552.3080601@apache.org> From: "Matthias J. Sax" Message-ID: <56BF5DA9.9090902@apache.org> Date: Sat, 13 Feb 2016 17:45:29 +0100 User-Agent: Mozilla/5.0 (X11; Linux x86_64; rv:38.0) Gecko/20100101 Icedove/38.5.0 MIME-Version: 1.0 In-Reply-To: Content-Type: multipart/signed; micalg=pgp-sha256; protocol="application/pgp-signature"; boundary="1Sfg9ErA9P7HnO8JBQumvSKLVBmTJIvop" This is an OpenPGP/MIME signed message (RFC 4880 and 3156) --1Sfg9ErA9P7HnO8JBQumvSKLVBmTJIvop Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: quoted-printable If your workload does not saturate a single machine, it will of course be more efficient to run within a single worker as you avoid intra-JVM communication. As long as CPU, memory, or network of a single machine is not utilized completely, you will not benefit from multiple workers from a performance point of view. Btw: I am a not sure what you mean by "I have to create a scenario..."? On 02/12/2016 11:42 PM, Rudraneel chakraborty wrote: > Thanks. Actually i have to create a scenario where 2 worker performs > better than one worker. But in reality , topology with a single worker > performs considerably better.=20 >=20 > I sending csv lines to kafka (5 partitions ) and reading them from a > topology with kafka spout (parallelism hint 5) >=20 > Any thoughts?=20 >=20 > On Thursday, 11 February 2016, Nathan Leung > wrote: >=20 > Any situation where you require more CPU than 1 server can provide > for you - there are tuning parameters (e.g. localOrShuffleGrouping)= > that you can use to reduce the amount of data sent over the network= too. >=20 > Any situation where you need to have tolerance in case of machine > failure. >=20 >=20 >=20 > On Thu, Feb 11, 2016 at 2:58 PM, Rudraneel chakraborty > > > wrote: >=20 > Topology param numWorkers i meant=20 >=20 >=20 > On Thursday, 11 February 2016, Rudraneel chakraborty > > > wrote: >=20 > More specifically , i have seen a topology performs better > if it is assigned a single worker compared to more than one= > worker.=20 >=20 > I want a situation where a topology performs better with > more than one worker. >=20 > And it doesnt matter if both workers are on same supervisor= > or different supervisor >=20 > On Thursday, 11 February 2016, Matthias J. Sax > wrote: >=20 > I am not sure what you mean: >=20 > - number of worker slots per supervisor > or > - topology parameter "number of workers" >=20 > Can you clarify? >=20 > -Matthias >=20 > On 02/11/2016 05:14 AM, anshu shukla wrote: > > Not like that.. But i have used workers equal to > number of cores. Each > > vm with 8 corea. > > > > On 11 Feb 2016 9:07 am, "Rudraneel chakraborty" > > > > wrote: > > > > more than one worker on same node ? Did u use > custom schedule r? > > because by default, the workers would be spread > throughout the cluster > > >=20 >=20 >=20 > --=20 > Rudraneel Chakraborty > Carleton University Real Time and Distributed Systems Reser= ach >=20 >=20 >=20 > --=20 > Rudraneel Chakraborty > Carleton University Real Time and Distributed Systems Reserach >=20 >=20 >=20 >=20 > --=20 > Rudraneel Chakraborty > Carleton University Real Time and Distributed Systems Reserach >=20 --1Sfg9ErA9P7HnO8JBQumvSKLVBmTJIvop Content-Type: application/pgp-signature; name="signature.asc" Content-Description: OpenPGP digital signature Content-Disposition: attachment; filename="signature.asc" -----BEGIN PGP SIGNATURE----- Version: GnuPG v2 iQIcBAEBCAAGBQJWv12tAAoJEFCVK48prEZ4G2MP/3Kt8qYhaKL19ybbzpiguE6Z Ao3B7HSM54y/Kskyzi/7E/GxiK+IjXLl5VZNpZ9yIQ/5SW04OPmUYVDwLFe2sYpt 7U0RTE+aVAF454Fh4yBTrFSfI3D0gBHHAQGxJoF2F9aQ5aWHaLmQr5sNzKjFSFMb /TdgO/kPtx5EfJSAhR1dkjesJMOC6i3GZRRYymK6AJ4906x9Ky54pgycWAZbFhiJ 3INh3+CLriAqOklbA5+wJmXW0T++J1EnRgZInNor3fwq/wuG/o2XCcNzyQW8Oab+ +8Hhx0FBX+UU1isH1bxjHi+EdEWL31DeXb4h6Dy5CXi+orf6hipp0Q81XsWHidre jJ2Byfik/q7B3eAIvUPRQEZ2BbwTwPkAF5n0K9XUbC+WpY694ko8Zc0MLqZxxv/h LN8zqFeTHkhxg3G1CLFquf4zCisyMT4F2qBewwkO5JLV/ZlQO8H3VjXyKZYEBNxe ZTczXdiriNw8fu1uHnJBDcDPLS8rUhwUgQ9Fi8q+rlrF4ULuMKJ7mBTFPRQd1n9/ jfkNGcPyEVU7IeH6mXYgMUFHUXQ444j4Mv2/aj3UCPu1I8dIVd2S06/qeNj9/etO h5l1TktQE+0InQGH4OPTyo0Ix4Mps/4+um9us2MZ6o/1hInT6uc2bMILuyc21wEf +ZWIhFQwdxVUXLPs9GJg =a+L/ -----END PGP SIGNATURE----- --1Sfg9ErA9P7HnO8JBQumvSKLVBmTJIvop--