[KAFKA-9897] Flaky Test StoreQueryIntegrationTest#shouldQuerySpecificActivePartitionStores

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 2.6.0
• Component/s: streams, unit tests
• Labels: flaky-test
• Assignee: Unassigned
• Reporter: Matthias J. Sax
• Created: 21/Apr/20 03:48
• Updated: 26/Feb/24 21:32
• Resolved: 05/Feb/24 13:45

Description

https://builds.apache.org/job/kafka-pr-jdk14-scala2.13/22/testReport/junit/org.apache.kafka.streams.integration/StoreQueryIntegrationTest/shouldQuerySpecificActivePartitionStores/

org.apache.kafka.streams.errors.InvalidStateStoreException: Cannot get state store source-table because the stream thread is PARTITIONS_ASSIGNED, not RUNNING at org.apache.kafka.streams.state.internals.StreamThreadStateStoreProvider.stores(StreamThreadStateStoreProvider.java:85) at org.apache.kafka.streams.state.internals.QueryableStoreProvider.getStore(QueryableStoreProvider.java:61) at org.apache.kafka.streams.KafkaStreams.store(KafkaStreams.java:1183) at org.apache.kafka.streams.integration.StoreQueryIntegrationTest.shouldQuerySpecificActivePartitionStores(StoreQueryIntegrationTest.java:178)

Issue Links

• relates to: KAFKA-9898 Flaky Test StoreQueryIntegrationTest.shouldQueryAllStalePartitionStores