[
https://issues.apache.org/jira/browse/KAFKA-16994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16994:
------------------------------------
Attachment:
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
> 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
> Priority: Major
> 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)
