[ https://issues.apache.org/jira/browse/KAFKA-4123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15472282#comment-15472282 ]
ASF GitHub Bot commented on KAFKA-4123: --------------------------------------- Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1824 > Queryable State returning null for key before all stores in instance have > been initialized > ------------------------------------------------------------------------------------------ > > Key: KAFKA-4123 > URL: https://issues.apache.org/jira/browse/KAFKA-4123 > Project: Kafka > Issue Type: Bug > Components: streams > Affects Versions: 0.10.1.0 > Reporter: Damian Guy > Assignee: Damian Guy > Fix For: 0.10.1.0 > > > A couple of problems: > 1. A RocksDBStore instance is currently marked as open before the store has > been initialized from its changelog. This can result in reading old/invalid > data when querying. > 2. In the case of multiple partitions and the tasks are being initialized it > is always possible that 1 or more StateStores will be intialized before the > complete set of stores in the Streams Instance are initialized. Currently > when this happens a query can return null because it will look in the > existing initialized stores. However, the key may exist in one of the > non-initialized instances. We need to wait for all Stores in the instance to > be initialized before allowing queries to progress. -- This message was sent by Atlassian JIRA (v6.3.4#6332)