[KAFKA-9783] Flaky Test QueryableStateIntegrationTest#concurrentAccesses

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 2.6.0
• Fix Version/s: 2.6.0
• Component/s: streams, unit tests
• Labels: flaky-test
• Assignee: Guozhang Wang
• Reporter: Matthias J. Sax
• Created: 28/Mar/20 17:42
• Updated: 31/Mar/20 23:42
• Resolved: 31/Mar/20 23:42

Description

https://builds.apache.org/job/kafka-pr-jdk8-scala2.12/1464/consoleFull

02:17:54 org.apache.kafka.streams.integration.QueryableStateIntegrationTest > concurrentAccesses FAILED*02:17:54* java.lang.AssertionError: Did not receive all 48 records from topic output-concurrent-2 within 120000 ms*02:17:54* Expected: is a value equal to or greater than <48>02:17:54 but: <0> was less than <48>02:17:54 at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20)02:17:54 at org.apache.kafka.streams.integration.utils.IntegrationTestUtils.lambda$waitUntilMinValuesRecordsReceived$6(IntegrationTestUtils.java:691)02:17:54 at org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:415)02:17:54 at org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:383)02:17:54 at org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinValuesRecordsReceived(IntegrationTestUtils.java:687)02:17:54 at org.apache.kafka.streams.integration.QueryableStateIntegrationTest.waitUntilAtLeastNumRecordProcessed(QueryableStateIntegrationTest.java:1199)02:17:54 at org.apache.kafka.streams.integration.QueryableStateIntegrationTest.concurrentAccesses(QueryableStateIntegrationTest.java:649)