You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by Margus Roo <ma...@roo.ee> on 2015/01/21 12:18:33 UTC
Spout emitter and transferred is bigger than ack
Hi
I have 1000 000 messages in kafka queue and I run topology with one
spout that is taking messages from kafka and one bolt who is putting
them to hbase.
After some minutes I can see that 1000 000 ack behind spout and 1000 000
ack behind bolt. And all 1000 000 messages are in hbase.
But spout's emitted and transferred are much bigger in example 2001660
in my last testing.
How I have to translate thous numbers?
--
Margus (margusja) Roo
http://margus.roo.ee
skype: margusja
+372 51 480
Re: Spout emitter and transferred is bigger than ack
Posted by Margus Roo <ma...@roo.ee>.
Okey topology stats emitted and transferred are sums of topology. But
topology stats ack are not.
Margus (margusja) Roo
http://margus.roo.ee
skype: margusja
+372 51 480
On 21/01/15 13:33, Margus Roo wrote:
> Last message was a little wrong.
> Numbers I mean are Topology stats - there are emitted and transferred
> bigger than ack.
>
> Margus (margusja) Roo
> http://margus.roo.ee
> skype: margusja
> +372 51 480
>
> On 21/01/15 13:18, Margus Roo wrote:
>> Hi
>>
>> I have 1000 000 messages in kafka queue and I run topology with one
>> spout that is taking messages from kafka and one bolt who is putting
>> them to hbase.
>> After some minutes I can see that 1000 000 ack behind spout and 1000
>> 000 ack behind bolt. And all 1000 000 messages are in hbase.
>> But spout's emitted and transferred are much bigger in example
>> 2001660 in my last testing.
>> How I have to translate thous numbers?
>>
>
Re: Spout emitter and transferred is bigger than ack
Posted by Margus Roo <ma...@roo.ee>.
Last message was a little wrong.
Numbers I mean are Topology stats - there are emitted and transferred
bigger than ack.
Margus (margusja) Roo
http://margus.roo.ee
skype: margusja
+372 51 480
On 21/01/15 13:18, Margus Roo wrote:
> Hi
>
> I have 1000 000 messages in kafka queue and I run topology with one
> spout that is taking messages from kafka and one bolt who is putting
> them to hbase.
> After some minutes I can see that 1000 000 ack behind spout and 1000
> 000 ack behind bolt. And all 1000 000 messages are in hbase.
> But spout's emitted and transferred are much bigger in example 2001660
> in my last testing.
> How I have to translate thous numbers?
>