[ https://issues.apache.org/jira/browse/KAFKA-14384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Lucas Brutschy resolved KAFKA-14384. ------------------------------------ Resolution: Fixed > Flaky Test > SelfJoinUpgradeIntegrationTest.shouldUpgradeWithTopologyOptimizationOff > ---------------------------------------------------------------------------------- > > Key: KAFKA-14384 > URL: https://issues.apache.org/jira/browse/KAFKA-14384 > Project: Kafka > Issue Type: Bug > Components: streams > Reporter: A. Sophie Blee-Goldman > Priority: Critical > Labels: flaky-test > > h3. Stacktrace > java.lang.AssertionError: Did not receive all 5 records from topic > selfjoin-outputSelfJoinUpgradeIntegrationTestshouldUpgradeWithTopologyOptimizationOff > within 60000 ms Expected: is a value equal to or greater than <5> but: <0> > was less than <5> at > org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20) at > org.apache.kafka.streams.integration.utils.IntegrationTestUtils.lambda$waitUntilMinKeyValueWithTimestampRecordsReceived$2(IntegrationTestUtils.java:763) > at > org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:382) > at > org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:350) > at > org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueWithTimestampRecordsReceived(IntegrationTestUtils.java:759) > at > org.apache.kafka.streams.integration.SelfJoinUpgradeIntegrationTest.processKeyValueAndVerifyCount(SelfJoinUpgradeIntegrationTest.java:244) > at > org.apache.kafka.streams.integration.SelfJoinUpgradeIntegrationTest.shouldUpgradeWithTopologyOptimizationOff(SelfJoinUpgradeIntegrationTest.java:155) > > https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-12835/4/testReport/org.apache.kafka.streams.integration/SelfJoinUpgradeIntegrationTest/Build___JDK_11_and_Scala_2_13___shouldUpgradeWithTopologyOptimizationOff/ -- This message was sent by Atlassian Jira (v8.20.10#820010)