Divij Vaidya created KAFKA-15095:
------------------------------------
Summary: Flaky test
EosV2UpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosV2[true]
Key: KAFKA-15095
URL: https://issues.apache.org/jira/browse/KAFKA-15095
Project: Kafka
Issue Type: Test
Components: unit tests
Reporter: Divij Vaidya
{code:java}
java.lang.AssertionError: Did not receive all 178 records from topic
multiPartitionOutputTopic within 60000 ms, currently accumulated data is
[KeyValue(1, 0), KeyValue(1, 1), KeyValue(1, 3), KeyValue(1, 6), KeyValue(1,
10), KeyValue(1, 15), KeyValue(1, 21), KeyValue(1, 28), KeyValue(1, 36),
KeyValue(1, 45), KeyValue(1, 55), KeyValue(1, 66), KeyValue(1, 78), KeyValue(1,
91), KeyValue(1, 105), KeyValue(1, 120), KeyValue(1, 136), KeyValue(1, 153),
KeyValue(1, 171), KeyValue(1, 190), KeyValue(1, 120), KeyValue(1, 136),
KeyValue(1, 153), KeyValue(1, 171), KeyValue(1, 190), KeyValue(1, 210),
KeyValue(1, 231), KeyValue(1, 253), KeyValue(1, 276), KeyValue(1, 300),
KeyValue(1, 325), KeyValue(1, 351), KeyValue(1, 378), KeyValue(1, 406),
KeyValue(1, 435), KeyValue(2, 0), KeyValue(2, 1), KeyValue(2, 3), KeyValue(2,
6), KeyValue(2, 10), KeyValue(2, 15), KeyValue(2, 21), KeyValue(2, 28),
KeyValue(2, 36), KeyValue(2, 45), KeyValue(2, 55), KeyValue(2, 66), KeyValue(2,
78), KeyValue(2, 91), KeyValue(2, 105), KeyValue(2, 55), KeyValue(2, 66),
KeyValue(2, 78), KeyValue(2, 91), KeyValue(2, 105), KeyValue(2, 120),
KeyValue(2, 136), KeyValue(2, 153), KeyValue(2, 171), KeyValue(2, 190),
KeyValue(2, 210), KeyValue(2, 231), KeyValue(2, 253), KeyValue(2, 276),
KeyValue(2, 300), KeyValue(2, 325), KeyValue(2, 351), KeyValue(2, 378),
KeyValue(2, 406), KeyValue(2, 435), KeyValue(2, 435), KeyValue(0, 0),
KeyValue(0, 1), KeyValue(0, 3), KeyValue(0, 6), KeyValue(0, 10), KeyValue(0,
15), KeyValue(0, 21), KeyValue(0, 28), KeyValue(0, 36), KeyValue(0, 45),
KeyValue(0, 55), KeyValue(0, 66), KeyValue(0, 78), KeyValue(0, 91), KeyValue(0,
55), KeyValue(0, 66), KeyValue(0, 78), KeyValue(0, 91), KeyValue(0, 105),
KeyValue(0, 120), KeyValue(0, 136), KeyValue(0, 153), KeyValue(0, 171),
KeyValue(0, 190), KeyValue(0, 210), KeyValue(0, 231), KeyValue(0, 253),
KeyValue(0, 276), KeyValue(0, 300), KeyValue(0, 325), KeyValue(0, 351),
KeyValue(0, 378), KeyValue(0, 406), KeyValue(0, 435), KeyValue(0, 325),
KeyValue(0, 351), KeyValue(0, 378), KeyValue(0, 406), KeyValue(0, 435),
KeyValue(3, 0), KeyValue(3, 1), KeyValue(3, 3), KeyValue(3, 6), KeyValue(3,
10), KeyValue(3, 15), KeyValue(3, 21), KeyValue(3, 28), KeyValue(3, 36),
KeyValue(3, 45), KeyValue(3, 55), KeyValue(3, 66), KeyValue(3, 78), KeyValue(3,
91), KeyValue(3, 105), KeyValue(3, 120), KeyValue(3, 136), KeyValue(3, 153),
KeyValue(3, 171), KeyValue(3, 190), KeyValue(3, 120), KeyValue(3, 136),
KeyValue(3, 153), KeyValue(3, 171), KeyValue(3, 190), KeyValue(3, 210),
KeyValue(3, 231), KeyValue(3, 253), KeyValue(3, 276), KeyValue(3, 300),
KeyValue(3, 325), KeyValue(3, 351), KeyValue(3, 378), KeyValue(3, 406),
KeyValue(3, 435), KeyValue(1, 465), KeyValue(1, 496), KeyValue(0, 465),
KeyValue(0, 496), KeyValue(3, 465), KeyValue(3, 496), KeyValue(0, 528),
KeyValue(1, 528), KeyValue(0, 561), KeyValue(1, 561), KeyValue(0, 595),
KeyValue(3, 528), KeyValue(2, 465), KeyValue(3, 561), KeyValue(2, 496),
KeyValue(3, 595), KeyValue(2, 528), KeyValue(2, 561), KeyValue(2,
595)]Expected: is a value equal to or greater than <178> but: <164> was
less than <178> at
org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20) at
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.lambda$waitUntilMinKeyValueRecordsReceived$1(IntegrationTestUtils.java:730)
at
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:379)
at
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:347)
at
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:726)
at
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:699)
at
org.apache.kafka.streams.integration.EosV2UpgradeIntegrationTest.readResult(EosV2UpgradeIntegrationTest.java:1080)
at
org.apache.kafka.streams.integration.EosV2UpgradeIntegrationTest.verifyUncommitted(EosV2UpgradeIntegrationTest.java:1055)
at
org.apache.kafka.streams.integration.EosV2UpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosV2(EosV2UpgradeIntegrationTest.java:705)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native
Method) at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:566) at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
at
org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:299)
at
org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:293)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at
java.base/java.lang.Thread.run(Thread.java:829) {code}
Sample build where this fails:
[https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-13858/3/tests]
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
