Description
Unit test on trunk gives occasional failure:
org.apache.kafka.streams.integration.KTableKTableJoinIntegrationTest > shouldInnerLeftJoin FAILED
java.lang.AssertionError: Condition not met within timeout 30000. Expecting 1 records from topic output- while only received 0: []
at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:265)
at org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:207)
at org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:176)
at org.apache.kafka.streams.integration.KTableKTableJoinIntegrationTest.verifyKTableKTableJoin(KTableKTableJoinIntegrationTest.java:222)
at org.apache.kafka.streams.integration.KTableKTableJoinIntegrationTest.shouldInnerLeftJoin(KTableKTableJoinIntegrationTest.java:143)
Attachments
Issue Links
- is related to
-
KAFKA-5005 JoinIntegrationTest fails occasionally
- Resolved
- links to