[KAFKA-10084] System test failure: StreamsEosTest.test_failure_and_recovery_complex

• Type: Task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 2.6.0, 2.7.0
• Fix Version/s: 2.6.0, 2.7.0
• Component/s: streams
• Assignee: John Roesler
• Reporter: John Roesler
• Created: 02/Jun/20 19:06
• Updated: 03/Jun/20 16:36
• Resolved: 03/Jun/20 16:36

Description

The test failed with message:

RemoteCommandError: ubuntu@worker14: Command 'grep ALL-RECORDS-DELIVERED /mnt/streams/streams.stdout' returned non-zero exit status 1.

And I found in the verifier's stderr:

java.lang.IllegalStateException: Offset for partition echo-1 is larger than topic endOffset: 2422 > 2421
	at org.apache.kafka.streams.tests.EosTestDriver.verifyAllTransactionFinished(EosTestDriver.java:604)
	at org.apache.kafka.streams.tests.EosTestDriver.verify(EosTestDriver.java:184)
	at org.apache.kafka.streams.tests.StreamsEosTest.main(StreamsEosTest.java:82)

 

Issue Links

• links to: GitHub Pull Request #8785