Luke Chen created KAFKA-12194:
---------------------------------

             Summary: fix flaky AdjustStreamThreadCountTest tests
                 Key: KAFKA-12194
                 URL: https://issues.apache.org/jira/browse/KAFKA-12194
             Project: Kafka
          Issue Type: Test
            Reporter: Luke Chen
            Assignee: Luke Chen


h3. Error Message

java.lang.AssertionError: Expected all streams instances in 
[org.apache.kafka.streams.KafkaStreams@7d253260] to be REBALANCING within 30000 
ms, but the following were not: 
\{org.apache.kafka.streams.KafkaStreams@7d253260=RUNNING}
h3. Stacktrace

java.lang.AssertionError: Expected all streams instances in 
[org.apache.kafka.streams.KafkaStreams@7d253260] to be REBALANCING within 30000 
ms, but the following were not: 
\{org.apache.kafka.streams.KafkaStreams@7d253260=RUNNING} at 
org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:26) at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.lambda$waitForApplicationState$12(IntegrationTestUtils.java:936)
 at 
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:350) 
at 
org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:318) 
at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitForApplicationState(IntegrationTestUtils.java:919)
 at 
org.apache.kafka.streams.integration.AdjustStreamThreadCountTest.shouldRemoveStreamThread(AdjustStreamThreadCountTest.java:134)

 

 

 

 

The error also applies to all tests in AdjustStreamThreadCountTest

 

https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk11/380/testReport/junit/org.apache.kafka.streams.integration/AdjustStreamThreadCountTest/shouldAddStreamThread/
https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk11/381/testReport/junit/org.apache.kafka.streams.integration/AdjustStreamThreadCountTest/shouldAddAndRemoveStreamThreadsWhileKeepingNamesCorrect/
https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk11/380/testReport/junit/org.apache.kafka.streams.integration/AdjustStreamThreadCountTest/shouldRemoveStreamThread/
https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk15/398/testReport/junit/org.apache.kafka.streams.integration/AdjustStreamThreadCountTest/shouldAddAndRemoveStreamThreadsWhileKeepingNamesCorrect/



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to