You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by Han Jia <jo...@gmail.com> on 2014/06/04 04:41:15 UTC
Trident Unexpected Tuple Error
Hi guys,
My trident topology threw a runtime exception. The topology reads from two
Kafka topics and generate two streams. One stream will be persisted into
trident states (cassandra) and the other will then query on the states. I
guess there is something wrong happened with the stream name. In the error
log, it's "$commit". I'm not sure what that means.
Has anyone encountered this kind of issue before? Any hints on what could
be the reason?
Thanks,
Han
Re: Trident Unexpected Tuple Error
Posted by Han Jia <jo...@gmail.com>.
HI Irek,
I'm not sure how to ensure that acking is happened in the same thread in
trident.
Could you provide suggestions on how to achieve it?
Thanks,
Han
On Tue, Jun 3, 2014 at 9:51 PM, Irek Khasyanov <qu...@gmail.com> wrote:
> Hey, are you acking in different thread? Exception is different as in wiki
> https://github.com/nathanmarz/storm/wiki/Troubleshooting#nullpointerexception-from-deep-inside-storm
> but maybe this can be helpful.
>
>
> On 4 June 2014 08:26, Han Jia <jo...@gmail.com> wrote:
>
>> Hi guys,
>>
>>
>> My trident topology threw a runtime exception. The topology reads from
>> two Kafka topics and generate two streams. One stream will be persisted
>> into trident states (cassandra) and the other will then query on the
>> states. I guess there is something wrong happened with the stream name. In
>> the error log, it's "$commit". I'm not sure what that means.
>>
>>
>> Has anyone encountered this kind of issue before? Any hints on what
>> could be the reason?
>>
>>
>> Thanks,
>> Han
>>
>>
>
>
> --
> With best regards, Irek Khasyanov.
>
Re: Trident Unexpected Tuple Error
Posted by Han Jia <jo...@gmail.com>.
Hi Nathan,
I've seen it for a couple of times. Do you have any idea on what could
potentially cause this kind of exception? Is it related to my parallelism
settings.
Thanks,
Han
On Thu, Jun 5, 2014 at 1:53 AM, Nathan Marz <na...@nathanmarz.com> wrote:
> Does this happen frequently or is it pretty rare?
>
>
> On Tue, Jun 3, 2014 at 9:51 PM, Irek Khasyanov <qu...@gmail.com> wrote:
>
>> Hey, are you acking in different thread? Exception is different as in
>> wiki
>> https://github.com/nathanmarz/storm/wiki/Troubleshooting#nullpointerexception-from-deep-inside-storm
>> but maybe this can be helpful.
>>
>>
>> On 4 June 2014 08:26, Han Jia <jo...@gmail.com> wrote:
>>
>>> Hi guys,
>>>
>>>
>>> My trident topology threw a runtime exception. The topology reads from
>>> two Kafka topics and generate two streams. One stream will be persisted
>>> into trident states (cassandra) and the other will then query on the
>>> states. I guess there is something wrong happened with the stream name. In
>>> the error log, it's "$commit". I'm not sure what that means.
>>>
>>>
>>> Has anyone encountered this kind of issue before? Any hints on what
>>> could be the reason?
>>>
>>>
>>> Thanks,
>>> Han
>>>
>>>
>>
>>
>> --
>> With best regards, Irek Khasyanov.
>>
>
>
>
> --
> Twitter: @nathanmarz
> http://nathanmarz.com
>
Re: Trident Unexpected Tuple Error
Posted by Nathan Marz <na...@nathanmarz.com>.
Does this happen frequently or is it pretty rare?
On Tue, Jun 3, 2014 at 9:51 PM, Irek Khasyanov <qu...@gmail.com> wrote:
> Hey, are you acking in different thread? Exception is different as in wiki
> https://github.com/nathanmarz/storm/wiki/Troubleshooting#nullpointerexception-from-deep-inside-storm
> but maybe this can be helpful.
>
>
> On 4 June 2014 08:26, Han Jia <jo...@gmail.com> wrote:
>
>> Hi guys,
>>
>>
>> My trident topology threw a runtime exception. The topology reads from
>> two Kafka topics and generate two streams. One stream will be persisted
>> into trident states (cassandra) and the other will then query on the
>> states. I guess there is something wrong happened with the stream name. In
>> the error log, it's "$commit". I'm not sure what that means.
>>
>>
>> Has anyone encountered this kind of issue before? Any hints on what
>> could be the reason?
>>
>>
>> Thanks,
>> Han
>>
>>
>
>
> --
> With best regards, Irek Khasyanov.
>
--
Twitter: @nathanmarz
http://nathanmarz.com
Re: Trident Unexpected Tuple Error
Posted by Irek Khasyanov <qu...@gmail.com>.
Hey, are you acking in different thread? Exception is different as in wiki
https://github.com/nathanmarz/storm/wiki/Troubleshooting#nullpointerexception-from-deep-inside-storm
but maybe this can be helpful.
On 4 June 2014 08:26, Han Jia <jo...@gmail.com> wrote:
> Hi guys,
>
>
> My trident topology threw a runtime exception. The topology reads from two
> Kafka topics and generate two streams. One stream will be persisted into
> trident states (cassandra) and the other will then query on the states. I
> guess there is something wrong happened with the stream name. In the error
> log, it's "$commit". I'm not sure what that means.
>
>
> Has anyone encountered this kind of issue before? Any hints on what could
> be the reason?
>
>
> Thanks,
> Han
>
>
--
With best regards, Irek Khasyanov.
Fwd: Trident Unexpected Tuple Error
Posted by Han Jia <jo...@gmail.com>.
Hi guys,
My trident topology threw a runtime exception. The topology reads from two
Kafka topics and generate two streams. One stream will be persisted into
trident states (cassandra) and the other will then query on the states. I
guess there is something wrong happened with the stream name. In the error
log, it's "$commit". I'm not sure what that means.
Has anyone encountered this kind of issue before? Any hints on what could
be the reason?
Thanks,
Han