[KAFKA-12194] fix flaky AdjustStreamThreadCountTest tests

• Type: Test
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 2.8.0
• Assignee: Luke Chen
• Reporter: Luke Chen
• Created: 14/Jan/21 08:50
• Updated: 19/Jan/21 05:42
• Resolved: 19/Jan/21 05:42

Description

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}

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/

Issue Links

• links to: GitHub Pull Request #9888