[jira] [Commented] (KAFKA-9897) Flaky Test StoreQueryIntegrationTest#shouldQuerySpecificActivePartitionStores

["Matthias J. Sax (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/KAFKA-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089052#comment-17089052 ] 

Matthias J. Sax commented on KAFKA-9897:
----------------------------------------

[~NaviBrar] – would you be interested to look into this one? You should have some context about the test. Would be nice if we could find and fix the root cause of the flakiness.

> Flaky Test StoreQueryIntegrationTest#shouldQuerySpecificActivePartitionStores
> -----------------------------------------------------------------------------
>
>                 Key: KAFKA-9897
>                 URL: https://issues.apache.org/jira/browse/KAFKA-9897
>             Project: Kafka
>          Issue Type: Bug
>          Components: streams, unit tests
>    Affects Versions: 2.6.0
>            Reporter: Matthias J. Sax
>            Priority: Critical
>              Labels: flaky-test
>
> [https://builds.apache.org/job/kafka-pr-jdk14-scala2.13/22/testReport/junit/org.apache.kafka.streams.integration/StoreQueryIntegrationTest/shouldQuerySpecificActivePartitionStores/]
> {quote}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){quote}



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