From user-return-9879-apmail-storm-user-archive=storm.apache.org@storm.apache.org Thu Feb 11 10:14:06 2016 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 34E5B18771 for ; Thu, 11 Feb 2016 10:14:06 +0000 (UTC) Received: (qmail 58764 invoked by uid 500); 11 Feb 2016 10:14:05 -0000 Delivered-To: apmail-storm-user-archive@storm.apache.org Received: (qmail 58721 invoked by uid 500); 11 Feb 2016 10:14:05 -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 58710 invoked by uid 99); 11 Feb 2016 10:14:05 -0000 Received: from Unknown (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 11 Feb 2016 10:14:05 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id E51EFC0B38 for ; Thu, 11 Feb 2016 10:14:04 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.18 X-Spam-Level: * X-Spam-Status: No, score=1.18 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, HTML_MESSAGE=2, MIME_QP_LONG_LINE=0.001, RCVD_IN_DNSWL_LOW=-0.7, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd1-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-eu-west.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id B-OIWp9ivkW9 for ; Thu, 11 Feb 2016 10:14:02 +0000 (UTC) Received: from mail-lb0-f182.google.com (mail-lb0-f182.google.com [209.85.217.182]) by mx1-eu-west.apache.org (ASF Mail Server at mx1-eu-west.apache.org) with ESMTPS id 0175A20CB8 for ; Thu, 11 Feb 2016 10:14:02 +0000 (UTC) Received: by mail-lb0-f182.google.com with SMTP id x4so25174087lbm.0 for ; Thu, 11 Feb 2016 02:14:01 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=user-agent:date:subject:from:to:message-id:thread-topic :mime-version:content-type; bh=tB9+e9jhhRlRh9pHe0hKWCRL6/BS5UcKB7+wT4LLQJQ=; b=fvDysoKdtCQxKjhpWIv3X1z8qeeNB7A32M0hHeStca5mjkZZrC8Z8Kbja35vX42Q+F prxr/tqNSIY0WONOFoYE01wpiDZip+P8UJTV1qjJ1NOaDbVlVMd3wkcoCYbW2Zja8oEz HCEV4zMZcwBHzgLYF9Xc1WTCvi1s5I1UJpk752ZA3VH3eLKyyHIByV+eM4FGfRaoxtIh SxWrkI0azS0KFsQBUDnRFfhn3W77Xx9KaHqAjy0AqbuEAiWeUBBOCtwdCAcG1RMZIWFB L4Jg/P4fHPhd8xsY3hRTs8ELEog9VTPkg/IRH4TSfkViAYKvxVOAw1gZXKrsvhs7SbbU TvoA== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:user-agent:date:subject:from:to:message-id :thread-topic:mime-version:content-type; bh=tB9+e9jhhRlRh9pHe0hKWCRL6/BS5UcKB7+wT4LLQJQ=; b=HIib8MYTx/ZcVTFXEX5jrb3flj7oV/YfCxyCYRbZ5GBFAAy/3vK38rYWxKHFr2xaAh /4Im0v8rfzSYaaFvp2FAGwJPuICK+oTNytBoA7b3YHH0UXavYSzCFh6geGajbKwIG8ZG QRI0VD7KVqgOmJX6xYNHGO1/4c2Dsx12Dq8ADAt9x4FVSBNzi54HOtgFbp9KT8N/WDMF rj0tEDOGOHah3UQYVq5633HjKsExnuaPVo9cEQ/iZPmhshTGHPiIPBxbgWCTJJ+mKpBo BSPKyqJbCqC/zXtfNnvg4xbH6hEMDCQYpbnGqVwjETKTY1ueLXa9vbMRVIUqRswkS/ea SMkg== X-Gm-Message-State: AG10YOQk1AkT8DbSynXdAbzTCmw73zQBmG15YYcMheOtGqWRRiMlYRzOxP7PZNeJXvJwRQ== X-Received: by 10.112.141.165 with SMTP id rp5mr18102437lbb.9.1455185641481; Thu, 11 Feb 2016 02:14:01 -0800 (PST) Received: from [192.168.161.67] ([91.247.221.60]) by smtp.gmail.com with ESMTPSA id o9sm1133196lfe.15.2016.02.11.02.14.00 for (version=TLSv1/SSLv3 cipher=OTHER); Thu, 11 Feb 2016 02:14:00 -0800 (PST) User-Agent: Microsoft-MacOutlook/0.0.0.150923 Date: Thu, 11 Feb 2016 12:13:58 +0200 Subject: Storm DRPC servers load balancing From: Victor Kovrizhkin To: Message-ID: <7A96C9A7-9992-49EC-9031-ECC0CED57A36@gmail.com> Thread-Topic: Storm DRPC servers load balancing Mime-version: 1.0 Content-type: multipart/alternative; boundary="B_3538037640_999320928" > This message is in MIME format. Since your mail reader does not understand this format, some or all of this message may not be legible. --B_3538037640_999320928 Content-type: text/plain; charset="UTF-8" Content-transfer-encoding: quoted-printable Hi everybody,=20 I=E2=80=99m trying to find out how to scale Storm DRPC server. As far as I can se= e from the documentation I can start several DRPC servers and configure my s= laves to know about them:=20 drpc.servers: - "drpc1.foo.com" - "drpc2.foo.com" On the other hand java client can connect only to one DRPC server (please c= orrect me if I=E2=80=99m wrong):=20 DRPCClient client =3D new DRPCClient("drpc-host", 3772); My concern here is that client should create DRPCClient instance per DRPC s= erver and choose manually where to execute query.=20 So the question is =E2=80=93 can you give me any idea how to balance the load acr= oss multiple Storm DRPC severs? Is it possible with java client? Thank you very much, Victor --B_3538037640_999320928 Content-type: text/html; charset="UTF-8" Content-transfer-encoding: quoted-printable
Hi everybody, 

I’m trying to find out how to scale St= orm DRPC server. As far as I can see from the documentation I can start seve= ral DRPC servers and configure my slaves to know about them: 

<= pre style=3D"color: rgb(51, 51, 51); font-family: Menlo, Monaco, Consolas, 'Co= urier New', monospace; font-size: 13px; background-color: rgb(245, 245, 245)= ; box-sizing: border-box; overflow: auto; padding: 9.5px; margin-top: 0px; m= argin-bottom: 10px; line-height: 1.42857143; word-break: break-all; word-wra= p: break-word; border: 1px solid rgb(204, 204, 204); border-top-left-radius:= 4px; border-top-right-radius: 4px; border-bottom-right-radius: 4px; border-= bottom-left-radius: 4px;">

On t= he other hand java client can connect only to one = ;DRPC server (please correct me if I’m wrong): 
= 

DRPCClient <=
span class=3D"n" style=3D"box-sizing: border-box;">client =3D new ("drpc-host", 3772);
<= /div>
My concern here is that client should create DRPCClient instance p= er DRPC server and choose manually where to execute query. 
<= br>
So the question is – can you give me any idea how to bal= ance the load across multiple Storm DRPC severs? Is it possible with java cl= ient?
Thank you very much,
Victor



--B_3538037640_999320928--