You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@storm.apache.org by "Basti Liu (JIRA)" <ji...@apache.org> on 2015/04/16 13:01:58 UTC

[jira] [Issue Comment Deleted] (STORM-512) KafkaBolt doesn't handle ticks properly

     [ https://issues.apache.org/jira/browse/STORM-512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Basti Liu updated STORM-512:
----------------------------
    Comment: was deleted

(was: I don't think it is necessary. Acker is not used to guarantee that tick tuple is processed. It does not make sense to call ack() here.
If "not ack" makes incorrect count of failuire message, the relative statistic part of core should be updated.)

> KafkaBolt doesn't handle ticks properly
> ---------------------------------------
>
>                 Key: STORM-512
>                 URL: https://issues.apache.org/jira/browse/STORM-512
>             Project: Apache Storm
>          Issue Type: Bug
>            Reporter: Niels Basjes
>            Assignee: Niels Basjes
>             Fix For: 0.11.0
>
>
> I found that when using the KafkaBolt the tick tuples are not handled properly. They should be ignored and the reality is that they are not.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)