unsubscribe
unsubscribe
Hi, all:
I've encountered the following NPE when storm tries to deserialize. I did
not use OutputCollector concurrently in my code. The only object we are
passing between bolts are a thrift object, and we have written a serializer
for it. I've attached the code of serializer and please help to c
It would be a good idea to take thread dump when logging stops. That could
give some clues
Excuse typos
On Mar 19, 2016 9:33 PM, "Denis DEBARBIEUX" wrote:
> Yes, I do.
>
> Denis
> --
> *De :* Abhishek Agarwal [abhishc...@gmail.com]
> *Date d'envoi :* vendredi 18 mars
Yes, I do.
Denis
De : Abhishek Agarwal [abhishc...@gmail.com]
Date d'envoi : vendredi 18 mars 2016 22:38
À : user@storm.apache.org
Objet : Re: Problem when consuming storm metrics
Do you get this problem if you use only the LoggingMetricsConsumer?
Excuse typos
On Mar 18, 2016 9:38 PM, "
Hi Sreeram,
Some ideas: One way to tolerate replays would be to use some type of CRDT
counter (https://en.wikipedia.org/wiki/Conflict-free_replicated_data_type).
Poor mans CRDT could be constructed if you have a strict ordering of your
messages through a monotonically increasing counter. Save the
Dear all,
I have a question about metrics and how they are consumed:
I launch my topology. During 3 or 4 minutes, I receive my metrics. Then
no more logs.
It's look like the process that is consuming the metrics has a dead lock
or is blocked by a time out.
Here comes some information about the c
Do you get this problem if you use only the LoggingMetricsConsumer?
Excuse typos
On Mar 18, 2016 9:38 PM, "Denis DEBARBIEUX" wrote:
> Dear all,
>
> I have a question about metrics and how they are consumed:
> I launch my topology. During 3 or 4 minutes, I receive my metrics. Then no
> more logs.
Hi,
I am looking for suggestions from community on implementing HBase atomic
increment in a idempotent manner from inside a storm bolt.
Replay of the storm bolt results in a double increment.
Any suggestion on the right approach to be taken is welcome.
Thank you.
Regards,
Sreeram
