[STORM-1404] Fix Mockito test failures in storm-kafka

• Type: Sub-task
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 1.0.0
• Component/s: storm-core
• Assignee: Haohui Mai
• Reporter: Derek Dagit
• Created: 18/Dec/15 19:33
• Updated: 11/Jan/16 15:15
• Resolved: 11/Jan/16 15:15

Description

Tests run: 8, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 17.194 sec <<< FAILURE! - in storm.kafka.bolt.KafkaBoltTest

executeWithByteArrayKeyAndMessageAsync(storm.kafka.bolt.KafkaBoltTest)  Time elapsed: 3.526 sec  <<< FAILURE!

org.mockito.exceptions.verification.WantedButNotInvoked: 

Wanted but not invoked:

collector.ack(

    source: null:1, stream: , id: {}, [[B@29e2aabd, [B@603773c6]

);

-> at storm.kafka.bolt.KafkaBoltTest.executeWithByteArrayKeyAndMessageAsync(KafkaBoltTest.java:144)

However, there were other interactions with this mock:

-> at backtype.storm.task.OutputCollector.reportError(OutputCollector.java:223)

-> at backtype.storm.task.OutputCollector.fail(OutputCollector.java:218)

	at storm.kafka.bolt.KafkaBoltTest.executeWithByteArrayKeyAndMessageAsync(KafkaBoltTest.java:144)

Seen here

Not sure about how often this happens, but it is definitely not 100% of the time.