[KAFKA-5063] Flaky ResetIntegrationTest.testReprocessingFromScratchAfterResetWithIntermediateUserTopic - ASF JIRA

Attach files

Attach Screenshot

Voters

Watch issue

Watchers

Create sub-task

Link

Clone

Update Comment Author

Replace String in Comment

Update Comment Visibility

Delete Comments

XML

Word

Printable

JSON

Details

Type: Bug
Status: Resolved
Priority: Major
Resolution: Cannot Reproduce
Affects Version/s: None
Fix Version/s: None
Component/s: streams, unit tests
Labels:
- unit-test

Description

org.apache.kafka.streams.integration.ResetIntegrationTest > testReprocessingFromScratchAfterResetWithIntermediateUserTopic FAILED
    java.lang.AssertionError: 
    Expected: <[KeyValue(2983939126775, 1), KeyValue(2983939126815, 1), KeyValue(2983939126835, 1), KeyValue(2983939126795, 1), KeyValue(2983939126815, 1), KeyValue(2983939126855, 1), KeyValue(2983939126835, 1), KeyValue(2983939126795, 1), KeyValue(2983939126815, 2), KeyValue(2983939126835, 2), KeyValue(2983939126855, 1), KeyValue(2983939126875, 1), KeyValue(2983939126835, 2), KeyValue(2983939126855, 2), KeyValue(2983939126895, 1), KeyValue(2983939126875, 1), KeyValue(2983939126855, 2), KeyValue(2983939126875, 2), KeyValue(2983939126895, 1), KeyValue(2983939126915, 1), KeyValue(2983939126875, 2), KeyValue(2983939126895, 2), KeyValue(2983939126915, 1), KeyValue(2983939126935, 1), KeyValue(2983939126875, 3), KeyValue(2983939126895, 2), KeyValue(2983939126915, 2), KeyValue(2983939126935, 1), KeyValue(2983939126875, 3), KeyValue(2983939126895, 3), KeyValue(2983939126915, 2), KeyValue(2983939126935, 2), KeyValue(2983939126875, 4), KeyValue(2983939126895, 3), KeyValue(2983939126915, 3), KeyValue(2983939126935, 2), KeyValue(2983939126875, 4), KeyValue(2983939126895, 4), KeyValue(2983939126915, 3), KeyValue(2983939126935, 3)]>
         but: was <[KeyValue(2983939126775, 1), KeyValue(2983939126815, 1), KeyValue(2983939126835, 1), KeyValue(2983939126795, 1), KeyValue(2983939126815, 1), KeyValue(2983939126855, 1), KeyValue(2983939126835, 1), KeyValue(2983939126795, 1), KeyValue(2983939126815, 2), KeyValue(2983939126835, 2), KeyValue(2983939126855, 1), KeyValue(2983939126875, 1), KeyValue(2983939126835, 2), KeyValue(2983939126855, 2), KeyValue(2983939126895, 1), KeyValue(2983939126875, 1), KeyValue(2983939126855, 2), KeyValue(2983939126875, 2), KeyValue(2983939126895, 1), KeyValue(2983939126915, 1), KeyValue(2983939126875, 2), KeyValue(2983939126895, 2), KeyValue(2983939126915, 1), KeyValue(2983939126935, 1), KeyValue(2983939126875, 3), KeyValue(2983939126895, 2), KeyValue(2983939126915, 2), KeyValue(2983939126935, 1), KeyValue(2983939126875, 3), KeyValue(2983939126895, 3), KeyValue(2983939126915, 2), KeyValue(2983939126935, 2), KeyValue(2983939126875, 4)]>
        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)