[
https://issues.apache.org/jira/browse/KAFKA-19641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Brutschy reassigned KAFKA-19641:
--------------------------------------
Assignee: Lucas Brutschy (was: Chia-Ping Tsai)
> Fix flaky
> RestoreIntegrationTest#shouldInvokeUserDefinedGlobalStateRestoreListener
> ----------------------------------------------------------------------------------
>
> Key: KAFKA-19641
> URL: https://issues.apache.org/jira/browse/KAFKA-19641
> Project: Kafka
> Issue Type: Test
> Components: streams, unit tests
> Reporter: Chia-Ping Tsai
> Assignee: Lucas Brutschy
> Priority: Minor
>
> org.opentest4j.AssertionFailedError: Condition not met within timeout 60000.
> Timed out waiting for active restoring task ==> expected: <true> but was:
> <false>
> at
> app//org.junit.jupiter.api.AssertionFailureBuilder.build(AssertionFailureBuilder.java:151)
> at
> app//org.junit.jupiter.api.AssertionFailureBuilder.buildAndThrow(AssertionFailureBuilder.java:132)
> at app//org.junit.jupiter.api.AssertTrue.failNotTrue(AssertTrue.java:63)
> at app//org.junit.jupiter.api.AssertTrue.assertTrue(AssertTrue.java:36)
> at app//org.junit.jupiter.api.Assertions.assertTrue(Assertions.java:214)
> at
> app//org.apache.kafka.test.TestUtils.lambda$waitForCondition$4(TestUtils.java:447)
> at
> app//org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:495)
> at
> app//org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:444)
> at
> app//org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:428)
> at
> app//org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:418)
> at
> app//org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitForActiveRestoringTask(IntegrationTestUtils.java:611)
> at
> app//org.apache.kafka.streams.integration.RestoreIntegrationTest.shouldInvokeUserDefinedGlobalStateRestoreListener(RestoreIntegrationTest.java:689)
> at java.base@17.0.16/java.lang.reflect.Method.invoke(Method.java:569)
> at java.base@17.0.16/java.util.Optional.ifPresent(Optional.java:178)
> at
> java.base@17.0.16/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
> at
> java.base@17.0.16/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
> at
> java.base@17.0.16/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
> at
> java.base@17.0.16/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
> at
> java.base@17.0.16/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
> at
> java.base@17.0.16/java.util.Spliterators$ArraySpliterator.forEachRemaining(Spliterators.java:992)
> at
> java.base@17.0.16/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
> at
> java.base@17.0.16/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
> at
> java.base@17.0.16/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
> at
> java.base@17.0.16/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
> at
> java.base@17.0.16/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
> at
> java.base@17.0.16/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596)
> at
> java.base@17.0.16/java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:276)
> at
> java.base@17.0.16/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1625)
> at
> java.base@17.0.16/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
> at
> java.base@17.0.16/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
> at
> java.base@17.0.16/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
> at
> java.base@17.0.16/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
> at
> java.base@17.0.16/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
> at
> java.base@17.0.16/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596)
> at
> java.base@17.0.16/java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:276)
> at
> java.base@17.0.16/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
> at
> java.base@17.0.16/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
> at
> java.base@17.0.16/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
> at
> java.base@17.0.16/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1625)
> at
> java.base@17.0.16/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
> at
> java.base@17.0.16/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
> at
> java.base@17.0.16/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
> at
> java.base@17.0.16/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
> at
> java.base@17.0.16/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
> at
> java.base@17.0.16/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596)
> at java.base@17.0.16/java.util.ArrayList.forEach(ArrayList.java:1511)
> at java.base@17.0.16/java.util.ArrayList.forEach(ArrayList.java:1511)
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
