You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2025/08/24 01:50:00 UTC
[jira] [Created] (KAFKA-19641) Fix flaky RestoreIntegrationTest#shouldInvokeUserDefinedGlobalStateRestoreListener
Chia-Ping Tsai created KAFKA-19641:
--------------------------------------
Summary: Fix flaky RestoreIntegrationTest#shouldInvokeUserDefinedGlobalStateRestoreListener
Key: KAFKA-19641
URL: https://issues.apache.org/jira/browse/KAFKA-19641
Project: Kafka
Issue Type: Test
Reporter: Chia-Ping Tsai
Assignee: Chia-Ping Tsai
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)