Mailing-List: contact user-help@storm.incubator.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@storm.incubator.apache.org
Received-SPF: pass (athena.apache.org: domain of ptgoetz@gmail.com designates
 209.85.220.52 as permitted sender)
From: "P. Taylor Goetz" <ptgoetz@gmail.com>
Content-Type: multipart/signed;
 boundary="Apple-Mail=_DF2A77BB-2635-4E1E-8E06-FC1C3AB02E2A";
 protocol="application/pgp-signature"; micalg=pgp-sha512
Message-Id: <20E2C3FA-850B-48FE-B1E4-9A34C0E35F1C@gmail.com>
Mime-Version: 1.0 (Mac OS X Mail 7.1 \(1827\))
Subject: Re: Is it possible to find out the active supervisor nodes through a
 program?
Date: Tue, 7 Jan 2014 14:15:21 -0800
References: 
 <CANMELZszE5qzfgEcxO5GiM4aVmN3Ek6wd=R91ohBne_OfXMZOg@mail.gmail.com>
To: user@storm.incubator.apache.org
In-Reply-To: 
 <CANMELZszE5qzfgEcxO5GiM4aVmN3Ek6wd=R91ohBne_OfXMZOg@mail.gmail.com>


--Apple-Mail=_DF2A77BB-2635-4E1E-8E06-FC1C3AB02E2A
Content-Type: multipart/alternative;
	boundary="Apple-Mail=_D9592CE1-82D9-4FE7-B172-2E1B92423139"


--Apple-Mail=_D9592CE1-82D9-4FE7-B172-2E1B92423139
Content-Transfer-Encoding: quoted-printable
Content-Type: text/plain;
	charset=windows-1252

Richards,

Yes, the Nimbus thrift interface provides an API for querying a Storm =
cluster, and is exactly what Storm UI uses to get the information it =
displays.=20

As far as =93active=94 supervisors, it depends on what you mean by =
=93active=94. If by active you mean =93up and known to Nimbus=94 then =
the list returned by the thrift API should be enough, if you mean =93has =
active worker processes=94 then you=92ll have to do additional work (not =
much) to see if it has any used slots.

HTH

- Taylor


On Jan 7, 2014, at 3:50 AM, Richards Peter <hbkrichards@gmail.com> =
wrote:

> Hi,
>=20
> I would like to know whether we can find out the list of active storm =
supervisor nodes? I checked the following class:
>=20
> =
https://github.com/apache/incubator-storm/blob/master/storm-core/src/jvm/b=
acktype/storm/generated/Nimbus.java
>=20
> It has a method -> getClusterInfo():ClusterSummary
>=20
>=20
> ClusterSummary internally has another method -> =
get_supervisors():List<SupervisorSummary>
>=20
> =
https://github.com/apache/incubator-storm/blob/master/storm-core/src/jvm/b=
acktype/storm/generated/SupervisorSummary.java
>=20
> Will this be able to tell me the list of all active supervisors? I =
would like to ignore the supervisors which are not active at the =
present. Is there a better way to achieve the same?
>=20
> Thanks,
> Richards Peter.


--Apple-Mail=_D9592CE1-82D9-4FE7-B172-2E1B92423139
Content-Transfer-Encoding: quoted-printable
Content-Type: text/html;
	charset=windows-1252

<html><head><meta http-equiv=3D"Content-Type" content=3D"text/html =
charset=3Dwindows-1252"></head><body style=3D"word-wrap: break-word; =
-webkit-nbsp-mode: space; -webkit-line-break: =
after-white-space;">Richards,<div><br></div><div>Yes, the Nimbus thrift =
interface provides an API for querying a Storm cluster, and is exactly =
what Storm UI uses to get the information it =
displays.&nbsp;</div><div><br></div><div>As far as =93active=94 =
supervisors, it depends on what you mean by =93active=94. If by active =
you mean =93up and known to Nimbus=94 then the list returned by the =
thrift API should be enough, if you mean =93has active worker processes=94=
 then you=92ll have to do additional work (not much) to see if it has =
any used slots.</div><div><br></div><div>HTH</div><div><br></div><div>- =
Taylor</div><div><br></div><div><br></div><div><div><div>On Jan 7, 2014, =
at 3:50 AM, Richards Peter &lt;<a =
href=3D"mailto:hbkrichards@gmail.com">hbkrichards@gmail.com</a>&gt; =
wrote:</div><br class=3D"Apple-interchange-newline"><blockquote =
type=3D"cite"><div dir=3D"ltr"><div><div><div><div><div>Hi,<br><br></div>I=
 would like to know whether we can find out the list of active storm =
supervisor nodes? I checked the following class:<br><br><a =
href=3D"https://github.com/apache/incubator-storm/blob/master/storm-core/s=
rc/jvm/backtype/storm/generated/Nimbus.java">https://github.com/apache/inc=
ubator-storm/blob/master/storm-core/src/jvm/backtype/storm/generated/Nimbu=
s.java</a><br>
<br></div>It has a method -&gt; <span =
class=3D"">getClusterInfo</span><span =
class=3D""></span>():ClusterSummary<br><br><br></div>ClusterSummary =
internally has another method -&gt; <span =
class=3D"">get_supervisors</span><span =
class=3D"">():List&lt;SupervisorSummary&gt;<br>
<br><a =
href=3D"https://github.com/apache/incubator-storm/blob/master/storm-core/s=
rc/jvm/backtype/storm/generated/SupervisorSummary.java">https://github.com=
/apache/incubator-storm/blob/master/storm-core/src/jvm/backtype/storm/gene=
rated/SupervisorSummary.java</a><br>
<br></span></div><span class=3D"">Will this be able to tell me the list =
of all active supervisors? I would like to ignore the supervisors which =
are not active at the present. Is there a better way to achieve the =
same?<br><br>
</span></div><span class=3D"">Thanks,<br>Richards =
Peter.<br></span></div>
</blockquote></div><br></div></body></html>=

--Apple-Mail=_D9592CE1-82D9-4FE7-B172-2E1B92423139--

--Apple-Mail=_DF2A77BB-2635-4E1E-8E06-FC1C3AB02E2A
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

iQEcBAEBCgAGBQJSzHx5AAoJEI3gOWLoC4/94GQH/iIjn88nqG/PT4tDjpQVwxoi
JJFxfGSKSrb/tu7oYMaf8ZYHpV2tWXh5zhruv1gQcx3LsI4g1vfjHKFfUUiGfHof
LcaWdEUobjB3hqBZXUI4jAzB4gyWNB1oAmoPJpSdm/U3mCpQgyU658fxxkV39IaS
WpGTBPGz+eM42am3oy1RASH2JwQTJp/tELnoChQ0lWPq1kqBQg4WCjxauHxQYRa/
+bIJ7HHr9P1bRL5SbB5QA0B3j4UK/UB3UJPx98Uk8ehpgCMaoXjsPpivds/dJmpp
VZjf2UKQj9yu6quCCq6V2fHnkp9IUdghcWgBRpHeW2Tdwe8dl3VDvmGdZexZ+So=
=lR9g
-----END PGP SIGNATURE-----

--Apple-Mail=_DF2A77BB-2635-4E1E-8E06-FC1C3AB02E2A--