[KAFKA-8743] Flaky Test RepartitionWithMergeOptimizingIntegrationTest#shouldSendCorrectRecords_OPTIMIZED

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 2.4.0
• Fix Version/s: 2.4.0
• Component/s: streams, unit tests
• Labels: flaky-test
• Assignee: A. Sophie Blee-Goldman
• Reporter: Matthias J. Sax
• Created: 01/Aug/19 18:45
• Updated: 10/Oct/19 23:25
• Resolved: 10/Oct/19 23:25

Description

https://builds.apache.org/job/kafka-pr-jdk11-scala2.12/6662/testReport/junit/org.apache.kafka.streams.integration/RepartitionWithMergeOptimizingIntegrationTest/shouldSendCorrectRecords_OPTIMIZED/

java.lang.AssertionError: Condition not met within timeout 60000. Did not receive all [KeyValue(A, 6), KeyValue(B, 6), KeyValue(C, 6)] records from topic outputTopic_0 at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:376) at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:353) at org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilFinalKeyValueRecordsReceived(IntegrationTestUtils.java:645) at org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilFinalKeyValueRecordsReceived(IntegrationTestUtils.java:595) at org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilFinalKeyValueRecordsReceived(IntegrationTestUtils.java:560) at org.apache.kafka.streams.integration.RepartitionWithMergeOptimizingIntegrationTest.runIntegrationTest(RepartitionWithMergeOptimizingIntegrationTest.java:164) at org.apache.kafka.streams.integration.RepartitionWithMergeOptimizingIntegrationTest.shouldSendCorrectRecords_OPTIMIZED(RepartitionWithMergeOptimizingIntegrationTest.java:105)

Issue Links

• links to: GitHub Pull Request #7472