[ 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)