[ https://issues.apache.org/jira/browse/KAFKA-5140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16198036#comment-16198036 ]
Jun Rao commented on KAFKA-5140: -------------------------------- Saw the following transient failures in a recent PR builder. https://builds.apache.org/job/kafka-pr-jdk8-scala2.12/8779/consoleFull org.apache.kafka.streams.integration.ResetIntegrationTest > testReprocessingFromScratchAfterResetWithIntermediateUserTopic FAILED java.lang.AssertionError: Condition not met within timeout 30000. Expecting 10 records from topic outputTopic while only received 0: [] at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:276) at org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:160) at org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:128) at org.apache.kafka.streams.integration.AbstractResetIntegrationTest.testReprocessingFromScratchAfterResetWithIntermediateUserTopic(AbstractResetIntegrationTest.java:289) at org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterResetWithIntermediateUserTopic(ResetIntegrationTest.java:63) org.apache.kafka.streams.integration.ResetIntegrationTest > testReprocessingFromScratchAfterResetWithoutIntermediateUserTopic STARTED org.apache.kafka.streams.integration.ResetIntegrationTest > testReprocessingFromScratchAfterResetWithoutIntermediateUserTopic FAILED java.lang.AssertionError: Expected: <[outputTopic, outputTopic2_rerun, inputTopic, outputTopic2, __consumer_offsets]> but: was <[outputTopic, outputTopic2_rerun, userTopic, outputTopic2, inputTopic, __consumer_offsets]> at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20) at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:8) at org.apache.kafka.streams.integration.AbstractResetIntegrationTest.assertInternalTopicsGotDeleted(AbstractResetIntegrationTest.java:470) at org.apache.kafka.streams.integration.AbstractResetIntegrationTest.testReprocessingFromScratchAfterResetWithoutIntermediateUserTopic(AbstractResetIntegrationTest.java:197) at org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterResetWithoutIntermediateUserTopic(ResetIntegrationTest.java:68) > Flaky ResetIntegrationTest > -------------------------- > > Key: KAFKA-5140 > URL: https://issues.apache.org/jira/browse/KAFKA-5140 > Project: Kafka > Issue Type: Bug > Components: streams, unit tests > Affects Versions: 0.10.2.0 > Reporter: Matthias J. Sax > Assignee: Matthias J. Sax > Fix For: 0.11.0.0 > > > {noformat} > org.apache.kafka.streams.integration.ResetIntegrationTest > > testReprocessingFromScratchAfterResetWithIntermediateUserTopic FAILED > java.lang.AssertionError: > Expected: <[KeyValue(2986681642095, 1), KeyValue(2986681642055, 1), > KeyValue(2986681642075, 1), KeyValue(2986681642035, 1), > KeyValue(2986681642095, 1), KeyValue(2986681642055, 1), > KeyValue(2986681642115, 1), KeyValue(2986681642075, 1), > KeyValue(2986681642075, 2), KeyValue(2986681642095, 2), > KeyValue(2986681642115, 1), KeyValue(2986681642135, 1), > KeyValue(2986681642095, 2), KeyValue(2986681642115, 2), > KeyValue(2986681642155, 1), KeyValue(2986681642135, 1), > KeyValue(2986681642115, 2), KeyValue(2986681642135, 2), > KeyValue(2986681642155, 1), KeyValue(2986681642175, 1), > KeyValue(2986681642135, 2), KeyValue(2986681642155, 2), > KeyValue(2986681642175, 1), KeyValue(2986681642195, 1), > KeyValue(2986681642135, 3), KeyValue(2986681642155, 2), > KeyValue(2986681642175, 2), KeyValue(2986681642195, 1), > KeyValue(2986681642155, 3), KeyValue(2986681642175, 2), > KeyValue(2986681642195, 2), KeyValue(2986681642155, 3), > KeyValue(2986681642175, 3), KeyValue(2986681642195, 2), > KeyValue(2986681642155, 4), KeyValue(2986681642175, 3), > KeyValue(2986681642195, 3)]> > but: was <[KeyValue(2986681642095, 1), KeyValue(2986681642055, 1), > KeyValue(2986681642075, 1), KeyValue(2986681642035, 1), > KeyValue(2986681642095, 1), KeyValue(2986681642055, 1), > KeyValue(2986681642115, 1), KeyValue(2986681642075, 1), > KeyValue(2986681642075, 2), KeyValue(2986681642095, 2), > KeyValue(2986681642115, 1), KeyValue(2986681642135, 1), > KeyValue(2986681642095, 2), KeyValue(2986681642115, 2), > KeyValue(2986681642155, 1), KeyValue(2986681642135, 1), > KeyValue(2986681642115, 2), KeyValue(2986681642135, 2), > KeyValue(2986681642155, 1), KeyValue(2986681642175, 1), > KeyValue(2986681642135, 2), KeyValue(2986681642155, 2), > KeyValue(2986681642175, 1), KeyValue(2986681642195, 1), > KeyValue(2986681642135, 3), KeyValue(2986681642155, 2), > KeyValue(2986681642175, 2), KeyValue(2986681642195, 1), > KeyValue(2986681642155, 3), KeyValue(2986681642175, 2), > KeyValue(2986681642195, 2), KeyValue(2986681642155, 3)]> > at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20) > at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:8) > at > org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterResetWithIntermediateUserTopic(ResetIntegrationTest.java:190) > {noformat} -- This message was sent by Atlassian JIRA (v6.4.14#64029)