Matthias J. Sax created KAFKA-16994:
---------------------------------------
Summary: Flaky Test
SlidingWindowedKStreamIntegrationTest.shouldRestoreAfterJoinRestart
Key: KAFKA-16994
URL: https://issues.apache.org/jira/browse/KAFKA-16994
Project: Kafka
Issue Type: Test
Reporter: Matthias J. Sax
Attachments:
5owo5xbyzjnao-org.apache.kafka.streams.integration.SlidingWindowedKStreamIntegrationTest-shouldRestoreAfterJoinRestart[ON_WINDOW_CLOSE_cache_true]-1-output.txt,
7jnraxqt7a52m-org.apache.kafka.streams.integration.SlidingWindowedKStreamIntegrationTest-shouldRestoreAfterJoinRestart[ON_WINDOW_CLOSE_cache_false]-1-output.txt,
dujhqmgv6nzuu-org.apache.kafka.streams.integration.SlidingWindowedKStreamIntegrationTest-shouldRestoreAfterJoinRestart[ON_WINDOW_UPDATE_cache_true]-1-output.txt,
fj6qia6oiob4m-org.apache.kafka.streams.integration.SlidingWindowedKStreamIntegrationTest-shouldRestoreAfterJoinRestart[ON_WINDOW_UPDATE_cache_false]-1-output.txt
Failed for all different parameters.
{code:java}
java.lang.AssertionError: Did not receive all 1 records from topic
output-shouldRestoreAfterJoinRestart_ON_WINDOW_CLOSE_cache_true_F_de0bULT5a8gQ_8lAhz8Q
within 60000 msExpected: is a value equal to or greater than <1> but: <0>
was less than <1>at
org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20)at
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.lambda$waitUntilMinKeyValueWithTimestampRecordsReceived$2(IntegrationTestUtils.java:778)at
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:444)at
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:412)at
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueWithTimestampRecordsReceived(IntegrationTestUtils.java:774)at
org.apache.kafka.streams.integration.SlidingWindowedKStreamIntegrationTest.receiveMessagesWithTimestamp(SlidingWindowedKStreamIntegrationTest.java:479)at
org.apache.kafka.streams.integration.SlidingWindowedKStreamIntegrationTest.shouldRestoreAfterJoinRestart(SlidingWindowedKStreamIntegrationTest.java:404)at
jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)at
jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)at
jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)at
java.lang.reflect.Method.invoke(Method.java:568)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.RunAfters.evaluate(RunAfters.java:27)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.util.concurrent.FutureTask.run(FutureTask.java:264)at
java.lang.Thread.run(Thread.java:833) {code}
{code:java}
java.lang.AssertionError: Did not receive all 2 records from topic
output-shouldRestoreAfterJoinRestart_ON_WINDOW_UPDATE_cache_true_bG_UnW1QSr_7tz2aXQNTXA
within 60000 msExpected: is a value equal to or greater than <2> but: <0>
was less than <2>at
org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20)at
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.lambda$waitUntilMinKeyValueWithTimestampRecordsReceived$2(IntegrationTestUtils.java:778)at
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:444)at
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:412)at
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueWithTimestampRecordsReceived(IntegrationTestUtils.java:774)at
org.apache.kafka.streams.integration.SlidingWindowedKStreamIntegrationTest.receiveMessagesWithTimestamp(SlidingWindowedKStreamIntegrationTest.java:479)at
org.apache.kafka.streams.integration.SlidingWindowedKStreamIntegrationTest.shouldRestoreAfterJoinRestart(SlidingWindowedKStreamIntegrationTest.java:404)at
jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103)at
java.lang.reflect.Method.invoke(Method.java:580)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.RunAfters.evaluate(RunAfters.java:27)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.util.concurrent.FutureTask.run(FutureTask.java:317)at
java.lang.Thread.run(Thread.java:1583) {code}
{code:java}
java.lang.AssertionError: Did not receive all 1 records from topic
output-shouldRestoreAfterJoinRestart_ON_WINDOW_CLOSE_cache_false_ueOeZHHfR5KNgw_OD6M0_A
within 60000 msExpected: is a value equal to or greater than <1> but: <0>
was less than <1>at
org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20)at
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.lambda$waitUntilMinKeyValueWithTimestampRecordsReceived$2(IntegrationTestUtils.java:778)at
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:444)at
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:412)at
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueWithTimestampRecordsReceived(IntegrationTestUtils.java:774)at
org.apache.kafka.streams.integration.SlidingWindowedKStreamIntegrationTest.receiveMessagesWithTimestamp(SlidingWindowedKStreamIntegrationTest.java:479)at
org.apache.kafka.streams.integration.SlidingWindowedKStreamIntegrationTest.shouldRestoreAfterJoinRestart(SlidingWindowedKStreamIntegrationTest.java:404)at
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)at
java.lang.reflect.Method.invoke(Method.java:498)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.RunAfters.evaluate(RunAfters.java:27)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.util.concurrent.FutureTask.run(FutureTask.java:266)at
java.lang.Thread.run(Thread.java:750) {code}
{code:java}
java.lang.AssertionError: Did not receive all 2 records from topic
output-shouldRestoreAfterJoinRestart_ON_WINDOW_UPDATE_cache_false_d6gbyh4JQRCBDB2fSJR0yQ
within 60000 msExpected: is a value equal to or greater than <2> but: <0>
was less than <2>at
org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20)at
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.lambda$waitUntilMinKeyValueWithTimestampRecordsReceived$2(IntegrationTestUtils.java:778)at
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:444)at
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:412)at
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueWithTimestampRecordsReceived(IntegrationTestUtils.java:774)at
org.apache.kafka.streams.integration.SlidingWindowedKStreamIntegrationTest.receiveMessagesWithTimestamp(SlidingWindowedKStreamIntegrationTest.java:479)at
org.apache.kafka.streams.integration.SlidingWindowedKStreamIntegrationTest.shouldRestoreAfterJoinRestart(SlidingWindowedKStreamIntegrationTest.java:404)at
jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)at
jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)at
jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)at
java.lang.reflect.Method.invoke(Method.java:568)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.RunAfters.evaluate(RunAfters.java:27)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.util.concurrent.FutureTask.run(FutureTask.java:264)at
java.lang.Thread.run(Thread.java:833) {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
