You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by Vincent Russell <vi...@gmail.com> on 2015/02/09 18:34:27 UTC
current tuples pending
Is there a way with storm to get a value for the current number of tuples
that haven't been acked yet?
Thanks,
Re: current tuples pending
Posted by Kosala Dissanayake <um...@gmail.com>.
You can also connect directly to Nimbus through its Thrift service.
(http://www.andys-sundaypink.com/i/retrieve-storm-cluster-statistic-from-nimbus-java-mode/
)
However I found it much easier to just use the REST API of the UI that Yury
mentioned, which will serve your purposes just fine.
On Wed, Feb 11, 2015 at 12:43 AM, Vincent Russell <vincent.russell@gmail.com
> wrote:
> Ok thanks. So I should be able to use a nimbus client to give me what I
> want.
> On Feb 10, 2015 5:53 AM, "Yury Ruchin" <yu...@gmail.com> wrote:
>
>> In Storm 0.9, there is REST API which you can use to query component- and
>> topology-level stats, including acked/transferred. Please refer to:
>> https://github.com/apache/storm/blob/master/STORM-UI-REST-API.md
>>
>> 2015-02-10 10:47 GMT+03:00 Vincent Russell <vi...@gmail.com>:
>>
>>> Sure. How can I get that programmatically?
>>> On Feb 10, 2015 2:13 AM, "Kosala Dissanayake" <um...@gmail.com>
>>> wrote:
>>>
>>>> Wouldn't that just be (transferred - acked)?
>>>>
>>>> On Tue, Feb 10, 2015 at 4:34 AM, Vincent Russell <
>>>> vincent.russell@gmail.com> wrote:
>>>>
>>>>>
>>>>> Is there a way with storm to get a value for the current number of
>>>>> tuples that haven't been acked yet?
>>>>>
>>>>>
>>>>> Thanks,
>>>>>
>>>>
>>>>
>>
Re: current tuples pending
Posted by Vincent Russell <vi...@gmail.com>.
Ok thanks. So I should be able to use a nimbus client to give me what I
want.
On Feb 10, 2015 5:53 AM, "Yury Ruchin" <yu...@gmail.com> wrote:
> In Storm 0.9, there is REST API which you can use to query component- and
> topology-level stats, including acked/transferred. Please refer to:
> https://github.com/apache/storm/blob/master/STORM-UI-REST-API.md
>
> 2015-02-10 10:47 GMT+03:00 Vincent Russell <vi...@gmail.com>:
>
>> Sure. How can I get that programmatically?
>> On Feb 10, 2015 2:13 AM, "Kosala Dissanayake" <um...@gmail.com>
>> wrote:
>>
>>> Wouldn't that just be (transferred - acked)?
>>>
>>> On Tue, Feb 10, 2015 at 4:34 AM, Vincent Russell <
>>> vincent.russell@gmail.com> wrote:
>>>
>>>>
>>>> Is there a way with storm to get a value for the current number of
>>>> tuples that haven't been acked yet?
>>>>
>>>>
>>>> Thanks,
>>>>
>>>
>>>
>
Re: current tuples pending
Posted by Yury Ruchin <yu...@gmail.com>.
In Storm 0.9, there is REST API which you can use to query component- and
topology-level stats, including acked/transferred. Please refer to:
https://github.com/apache/storm/blob/master/STORM-UI-REST-API.md
2015-02-10 10:47 GMT+03:00 Vincent Russell <vi...@gmail.com>:
> Sure. How can I get that programmatically?
> On Feb 10, 2015 2:13 AM, "Kosala Dissanayake" <um...@gmail.com>
> wrote:
>
>> Wouldn't that just be (transferred - acked)?
>>
>> On Tue, Feb 10, 2015 at 4:34 AM, Vincent Russell <
>> vincent.russell@gmail.com> wrote:
>>
>>>
>>> Is there a way with storm to get a value for the current number of
>>> tuples that haven't been acked yet?
>>>
>>>
>>> Thanks,
>>>
>>
>>
Re: current tuples pending
Posted by Vincent Russell <vi...@gmail.com>.
Sure. How can I get that programmatically?
On Feb 10, 2015 2:13 AM, "Kosala Dissanayake" <um...@gmail.com> wrote:
> Wouldn't that just be (transferred - acked)?
>
> On Tue, Feb 10, 2015 at 4:34 AM, Vincent Russell <
> vincent.russell@gmail.com> wrote:
>
>>
>> Is there a way with storm to get a value for the current number of tuples
>> that haven't been acked yet?
>>
>>
>> Thanks,
>>
>
>
Re: current tuples pending
Posted by Kosala Dissanayake <um...@gmail.com>.
Wouldn't that just be (transferred - acked)?
On Tue, Feb 10, 2015 at 4:34 AM, Vincent Russell <vi...@gmail.com>
wrote:
>
> Is there a way with storm to get a value for the current number of tuples
> that haven't been acked yet?
>
>
> Thanks,
>