[KAFKA-15797] Flaky test EosV2UpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosV2[true]

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Component/s: streams, unit tests
• Labels: flaky-test
• Assignee: Matthias J. Sax
• Reporter: Justine Olshan
• Created: 07/Nov/23 21:55
• Updated: 06/Mar/24 18:27
• Resolved: 06/Mar/24 18:27

Description

I found two recent failures:

https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-14629/22/testReport/junit/org.apache.kafka.streams.integration/EosV2UpgradeIntegrationTest/Build___JDK_8_and_Scala_2_12___shouldUpgradeFromEosAlphaToEosV2_true_/
https://ci-builds.apache.org/job/Kafka/job/kafka/job/trunk/2365/testReport/junit/org.apache.kafka.streams.integration/EosV2UpgradeIntegrationTest/Build___JDK_21_and_Scala_2_13___shouldUpgradeFromEosAlphaToEosV2_true__2/ 

Output generally looks like:

java.lang.AssertionError: Did not receive all 138 records from topic multiPartitionOutputTopic within 60000 ms, currently accumulated data is [KeyValue(0, 0), KeyValue(0, 1), KeyValue(0, 3), KeyValue(0, 6), KeyValue(0, 10), KeyValue(0, 15), KeyValue(0, 21), KeyValue(0, 28), KeyValue(0, 36), KeyValue(0, 45), KeyValue(0, 55), KeyValue(0, 66), KeyValue(0, 78), KeyValue(0, 91), KeyValue(0, 55), KeyValue(0, 66), KeyValue(0, 78), KeyValue(0, 91), KeyValue(0, 105), KeyValue(0, 120), KeyValue(0, 136), KeyValue(0, 153), KeyValue(0, 171), KeyValue(0, 190), KeyValue(3, 0), KeyValue(3, 1), KeyValue(3, 3), KeyValue(3, 6), KeyValue(3, 10), KeyValue(3, 15), KeyValue(3, 21), KeyValue(3, 28), KeyValue(3, 36), KeyValue(3, 45), KeyValue(3, 55), KeyValue(3, 66), KeyValue(3, 78), KeyValue(3, 91), KeyValue(3, 105), KeyValue(3, 120), KeyValue(3, 136), KeyValue(3, 153), KeyValue(3, 171), KeyValue(3, 190), KeyValue(3, 190), KeyValue(3, 210), KeyValue(3, 231), KeyValue(3, 253), KeyValue(3, 276), KeyValue(3, 300), KeyValue(3, 325), KeyValue(3, 351), KeyValue(3, 378), KeyValue(3, 406), KeyValue(3, 435), KeyValue(1, 0), KeyValue(1, 1), KeyValue(1, 3), KeyValue(1, 6), KeyValue(1, 10), KeyValue(1, 15), KeyValue(1, 21), KeyValue(1, 28), KeyValue(1, 36), KeyValue(1, 45), KeyValue(1, 55), KeyValue(1, 66), KeyValue(1, 78), KeyValue(1, 91), KeyValue(1, 105), KeyValue(1, 120), KeyValue(1, 136), KeyValue(1, 153), KeyValue(1, 171), KeyValue(1, 190), KeyValue(1, 120), KeyValue(1, 136), KeyValue(1, 153), KeyValue(1, 171), KeyValue(1, 190), KeyValue(1, 210), KeyValue(1, 231), KeyValue(1, 253), KeyValue(1, 276), KeyValue(1, 300), KeyValue(1, 325), KeyValue(1, 351), KeyValue(1, 378), KeyValue(1, 406), KeyValue(1, 435), KeyValue(2, 0), KeyValue(2, 1), KeyValue(2, 3), KeyValue(2, 6), KeyValue(2, 10), KeyValue(2, 15), KeyValue(2, 21), KeyValue(2, 28), KeyValue(2, 36), KeyValue(2, 45), KeyValue(2, 55), KeyValue(2, 66), KeyValue(2, 78), KeyValue(2, 91), KeyValue(2, 105), KeyValue(2, 55), KeyValue(2, 66), KeyValue(2, 78), KeyValue(2, 91), KeyValue(2, 105), KeyValue(2, 120), KeyValue(2, 136), KeyValue(2, 153), KeyValue(2, 171), KeyValue(2, 190), KeyValue(2, 210), KeyValue(2, 231), KeyValue(2, 253), KeyValue(2, 276), KeyValue(2, 300), KeyValue(2, 325), KeyValue(2, 351), KeyValue(2, 378), KeyValue(2, 406), KeyValue(0, 210), KeyValue(0, 231), KeyValue(0, 253), KeyValue(0, 276), KeyValue(0, 300), KeyValue(0, 325), KeyValue(0, 351), KeyValue(0, 378), KeyValue(0, 406), KeyValue(0, 435)] Expected: is a value equal to or greater than <138> but: <134> was less than <138>

Issue Links

• links to: GitHub Pull Request #15449