You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Sophie Blee-Goldman (JIRA)" <ji...@apache.org> on 2019/03/26 21:47:00 UTC
[jira] [Updated] (KAFKA-8159) Multi-key range queries with negative
keyFrom results in unexpected behavior
[ https://issues.apache.org/jira/browse/KAFKA-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Sophie Blee-Goldman updated KAFKA-8159:
---------------------------------------
Description:
If a user creates a queryable state store using one of the signed built-in serdes (eg Integer) for the key, there is nothing preventing records with negative keys from being inserted and/or fetched individually. However if the user tries to query the store for a range of keys starting with a negative number, unexpected behavior results that is store-specific.
For RocksDB stores with caching disabled, Streams will silently miss and negative keys and return those from the range [0, keyTo].
For in-memory stores and ANY store with caching enabled, Streams will throw an unchecked exception and crash.
This situation should be handled more gracefully, or users should be informed of this limitation and the result should at least be consist across types of store.
was:
If a user creates a queryable state store using one of the signed built-in serdes (eg Integer) for the key, there is nothing preventing records with negative keys from being inserted and/or fetched individually. However if the user tries to query the store for a range of keys starting with a negative number, unexpected behavior results that is store-specific.
For RocksDB stores with caching disabled, Streams will silently miss and negative keys and return those from the range [0, keyTo].
For in-memory stores and ANY store with caching enabled, Streams will throw an unchecked exception and crash.
This situation should be handled more gracefully, or users should be informed of this limitation and the result should at least be consist across types of store.
> Multi-key range queries with negative keyFrom results in unexpected behavior
> ----------------------------------------------------------------------------
>
> Key: KAFKA-8159
> URL: https://issues.apache.org/jira/browse/KAFKA-8159
> Project: Kafka
> Issue Type: Bug
> Reporter: Sophie Blee-Goldman
> Priority: Major
> Labels: streams
>
> If a user creates a queryable state store using one of the signed built-in serdes (eg Integer) for the key, there is nothing preventing records with negative keys from being inserted and/or fetched individually. However if the user tries to query the store for a range of keys starting with a negative number, unexpected behavior results that is store-specific.
>
> For RocksDB stores with caching disabled, Streams will silently miss and negative keys and return those from the range [0, keyTo].
> For in-memory stores and ANY store with caching enabled, Streams will throw an unchecked exception and crash.
>
> This situation should be handled more gracefully, or users should be informed of this limitation and the result should at least be consist across types of store.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)