[ https://issues.apache.org/jira/browse/STORM-2403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jungtaek Lim resolved STORM-2403. --------------------------------- Resolution: Fixed Fix Version/s: 1.0.4 1.1.0 2.0.0 Merged into master, 1.x, 1.0.x branches. > Fix KafkaBolt test failure: tick tuple should not be acked > ---------------------------------------------------------- > > Key: STORM-2403 > URL: https://issues.apache.org/jira/browse/STORM-2403 > Project: Apache Storm > Issue Type: Bug > Components: storm-kafka > Affects Versions: 2.0.0, 1.1.0, 1.0.4 > Reporter: Jungtaek Lim > Assignee: Jungtaek Lim > Priority: Blocker > Fix For: 2.0.0, 1.1.0, 1.0.4 > > Time Spent: 0.5h > Remaining Estimate: 0h > > From STORM-2387, I changed KafkaBolt to make sure it doesn't ack tick tuples. > (Tick tuples are generated from each executor and don't trigger ACK_INIT so > actually it should not be acked. Acker will keep them and remove some for > message timeout so not a big deal though.) > But I forgot to fix unit test for that, and also missed to check test result. > This issue is for making quick fix for that. -- This message was sent by Atlassian JIRA (v6.3.15#6346)