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 CA31D1071D for ; Wed, 5 Feb 2014 15:59:18 +0000 (UTC) Received: (qmail 41220 invoked by uid 500); 5 Feb 2014 15:59:18 -0000 Delivered-To: apmail-storm-user-archive@storm.apache.org Received: (qmail 41164 invoked by uid 500); 5 Feb 2014 15:59:18 -0000 Mailing-List: contact user-help@storm.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@storm.incubator.apache.org Delivered-To: mailing list user@storm.incubator.apache.org Received: (qmail 41153 invoked by uid 99); 5 Feb 2014 15:59:17 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 05 Feb 2014 15:59:17 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of ptgoetz@gmail.com designates 209.85.216.46 as permitted sender) Received: from [209.85.216.46] (HELO mail-qa0-f46.google.com) (209.85.216.46) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 05 Feb 2014 15:59:13 +0000 Received: by mail-qa0-f46.google.com with SMTP id ii20so794351qab.5 for ; Wed, 05 Feb 2014 07:58:52 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=from:content-type:message-id:mime-version:subject:date:references :to:in-reply-to; bh=F0gc3w++BdWH1D9cWMOWWwXae4giSX/dQnoVWvFBi3U=; b=tdXqexn4RinhEOoboZpDRHXJ4j5o0aax4iWiOxpBSVCLO+cM6w29LymQXePtifV6p9 waHnfHRf3N0o8h5OWldvLaXP83jnaLkwMOsX9923MFOPIa3KQIxmt8GI+BAnTLp5CkuR hxTuECRAwrtnbX9pzBD2T45uDhRq1OnQfZlaTbeAsdtYJcyrq5rFO6fz9oiT3pVVICIL a+5n4MOBAjfBolMsUL+aHgpJrgXmcgPdqaJuJr9ik5AqstP1+6vpxkO4G0pFXC1vJjSl l0RkN6bujs1gNP7+iyMzUUfO9MxuV9IixdAafKw2qP/NAxTYLX+pSCmtm6bDPyCZ4ll/ G/Hg== X-Received: by 10.229.127.72 with SMTP id f8mr1253429qcs.12.1391615932331; Wed, 05 Feb 2014 07:58:52 -0800 (PST) Received: from new-host-5.local (pool-173-59-54-41.phlapa.fios.verizon.net. [173.59.54.41]) by mx.google.com with ESMTPSA id y71sm37588440qgd.3.2014.02.05.07.58.50 for (version=TLSv1 cipher=ECDHE-RSA-RC4-SHA bits=128/128); Wed, 05 Feb 2014 07:58:51 -0800 (PST) From: "P. Taylor Goetz" Content-Type: multipart/signed; boundary="Apple-Mail=_9BE6610D-3744-4005-8EDA-68B0794F6A8A"; protocol="application/pgp-signature"; micalg=pgp-sha512 Message-Id: <9499419A-1FF1-4D56-AFA4-6E94EDE44F31@gmail.com> Mime-Version: 1.0 (Mac OS X Mail 7.1 \(1827\)) Subject: Re: Rebalance topology throws java.lang.StringIndexOutOfBoundsException: String index out of range: -1 Date: Wed, 5 Feb 2014 10:58:49 -0500 References: To: user@storm.incubator.apache.org In-Reply-To: X-Mailer: Apple Mail (2.1827) X-Virus-Checked: Checked by ClamAV on apache.org --Apple-Mail=_9BE6610D-3744-4005-8EDA-68B0794F6A8A Content-Type: multipart/alternative; boundary="Apple-Mail=_DA5C2533-EF53-4FAC-A503-9FCD37EF2068" --Apple-Mail=_DA5C2533-EF53-4FAC-A503-9FCD37EF2068 Content-Transfer-Encoding: quoted-printable Content-Type: text/plain; charset=iso-8859-1 Hi Florin, I opened an issue to track this: https://issues.apache.org/jira/browse/STORM-214 Regards, Taylor On Feb 5, 2014, at 4:30 AM, Spico Florin wrote: >=20 > Hello! > In the mentioned version for Windows, the rebalance command arguments = should not be passed as indicated in=20 >=20 > = https://github.com/nathanmarz/storm/wiki/Understanding-the-parallelism-of-= a-Storm-topology > storm rebalance mytopology -n 5 -e blue-spout=3D3 -e yellow-bolt=3D10 >=20 > In order to get rid of the mentioned = exception(java.lang.StringIndexOutOfBoundsException:) you should use the = command > =20 > storm rebalance WordCount -e "spout=3D3" >=20 > However, trying to rebalance more components (either spouts or bolts) = will rebalance only the latest component mentioned in the list. So, for = example for example: >=20 > storm rebalance WordCount -e "spout=3D3" -e "count=3D5" > the rebalance will be applied only for the "count" component not for = the "spout". >=20 > So, in my opinion either the documentation should be updated or the = rebalance.clj should be changed in order to support rebalancing for = multiple components. >=20 > I look forward for your opinions. > Regards, > Florin >=20 >=20 >=20 >=20 >=20 >=20 > ---------- Forwarded message ---------- > From: Spico Florin > Date: Tue, Feb 4, 2014 at 11:10 AM > Subject: Rebalance topology throws = java.lang.StringIndexOutOfBoundsException: String index out of range: -1 > To: "user@storm.incubator.apache.org" = >=20 >=20 > Hello! > I'm using the Taylor Goetz's storm version pointed out by article=20 >=20 > = http://ptgoetz.github.io/blog/2013/12/18/running-apache-storm-on-windows/ >=20 > and located at: > https://github.com/ptgoetz/incubator-storm/tree/windows-test >=20 > I have succeeded to install everything on my computer (running windows = 7, 64 bit). I have also ran fine the indicated topology and my topology = too. But when I'm trying to do a rebalancing of my topology by = re-configuring the number of spouts or bolt with the command =20 > storm rebalance WordCount -e spout=3D3 > I'm getting the exception: > Exception in thread "main" java.lang.StringIndexOutOfBoundsException: = String index out of range: -1 > at java.lang.String.substring(String.java:1911) > at = backtype.storm.command.rebalance$parse_executor.invoke(rebalance.clj:24) > at clojure.tools.cli$apply_specs.invoke(cli.clj:80) > at clojure.tools.cli$cli.doInvoke(cli.clj:130) > at clojure.lang.RestFn.invoke(RestFn.java:460) > at = backtype.storm.command.rebalance$_main.doInvoke(rebalance.clj:31) > at clojure.lang.RestFn.applyTo(RestFn.java:137) > at backtype.storm.command.rebalance.main(Unknown Source) >=20 > If I'm changing only the number of workers it works without any = exceptions. >=20 > If someone of you have tested this version, can you please help me to = get rid of it? > I'll look forward for your answers. >=20 > Thanks in advance. > Regards, > Florin=20 >=20 >=20 >=20 --Apple-Mail=_DA5C2533-EF53-4FAC-A503-9FCD37EF2068 Content-Transfer-Encoding: quoted-printable Content-Type: text/html; charset=iso-8859-1 Hi = Florin,

I opened an issue to track = this:


Regards,
=

Taylor

On Feb 5, 2014, at = 4:30 AM, Spico Florin <spicoflorin@gmail.com> = wrote:


Hello!
In the = mentioned version for Windows, the  rebalance command arguments = should not be passed as indicated in

https://github.com/nathanmarz/storm/wiki/Underst= anding-the-parallelism-of-a-Storm-topology
storm rebalance =
mytopology -n 5 -e blue-spout=3D3 -e =
yellow-bolt=3D10

In order to get rid of the mentioned = exception(java.lang.StringIndexOutOfBoundsException:) you should use the = command
 
storm rebalance WordCount -e = "spout=3D3"

However, trying to rebalance more = components (either spouts or bolts) will rebalance only the latest = component mentioned in the list. So, for example for example:

storm rebalance WordCount -e "spout=3D3" -e "count=3D5"
 the = rebalance will be applied only for the "count" component not for the = "spout".

So, in my opinion either the documentation = should be updated or the rebalance.clj should be changed in order to = support rebalancing for multiple components.

I look forward for your opinions.
  = Regards,
  = Florin






---------- Forwarded message ----------
From: = Spico Florin <spicoflorin@gmail.com>=
Date: Tue, Feb 4, 2014 at 11:10 AM
Subject: Rebalance topology throws = java.lang.StringIndexOutOfBoundsException: String index out of range: = -1
To: "user@storm.incubator.apach= e.org" <user@storm.incubator.apach= e.org>


Hello!
I'm using the Taylor = Goetz's storm version pointed out by = article 


and located at:
https://github.com/ptgoetz/incubator-storm/tree/windows-= test

I have succeeded to install everything on my computer (running windows = 7, 64 bit). I have also ran fine the indicated topology and my topology = too. But when I'm trying to do a rebalancing of my topology by = re-configuring the number of spouts or bolt with the command =  
  storm rebalance WordCount -e spout=3D3
I'm = getting the exception:
Exception in thread "main" = java.lang.StringIndexOutOfBoundsException: String index out of range: = -1
        at = java.lang.String.substring(String.java:1911)
    =     at = backtype.storm.command.rebalance$parse_executor.invoke(rebalance.clj:24)
        at = clojure.tools.cli$apply_specs.invoke(cli.clj:80)
        at = clojure.tools.cli$cli.doInvoke(cli.clj:130)
    =     at = clojure.lang.RestFn.invoke(RestFn.java:460)
    =     at = backtype.storm.command.rebalance$_main.doInvoke(rebalance.clj:31)
        at = clojure.lang.RestFn.applyTo(RestFn.java:137)
    =     at backtype.storm.command.rebalance.main(Unknown = Source)

If I'm changing only the number = of workers it works without any exceptions.

If someone of you have tested this version, can you = please help me to get rid of it?
I'll look forward for your = answers.

Thanks in advance.
  = Regards,
  Florin 




= --Apple-Mail=_DA5C2533-EF53-4FAC-A503-9FCD37EF2068-- --Apple-Mail=_9BE6610D-3744-4005-8EDA-68B0794F6A8A Content-Transfer-Encoding: 7bit Content-Disposition: attachment; filename=signature.asc Content-Type: application/pgp-signature; name=signature.asc Content-Description: Message signed with OpenPGP using GPGMail -----BEGIN PGP SIGNATURE----- Comment: GPGTools - https://gpgtools.org iQEcBAEBCgAGBQJS8l+5AAoJEI3gOWLoC4/9cloIAOjWKA76LRS2KktgsKnaBxOK 3ejSxqwWMzM94rcmZUoYmaJiKyKHlGZD43Pm9QAq7WtHYwK3cCJxPEGXmJHcfJN6 uCvOkl+CiwdxKluL0FU3v7p1KxnQkcj6B8zclDnjQ/6kY35dxXXbOs6BALO2jMHH 0BoYnuXxjCQquWTS0TPeZ+VclaaC3tGBtQHyg0GMJrG01Ek/zuIn+ll37NkAaYat WAwnC8H24w4wfd0X4yPhAITLvFJw2a2ggLVHFD2F02GnEChMwTrkMREZvlqgLGkP 5pIG62zGNTfZK33+aiO8swSP7MChdF4hSrKk49ImJXToBAFo50Oj5xzd2DwPeeE= =6Yqd -----END PGP SIGNATURE----- --Apple-Mail=_9BE6610D-3744-4005-8EDA-68B0794F6A8A--