flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Kostas Kloudas (JIRA)" <j...@apache.org>
Subject [jira] [Assigned] (FLINK-5961) Queryable State is broken for HeapKeyedStateBackend
Date Thu, 29 Jun 2017 17:07:01 GMT

     [ https://issues.apache.org/jira/browse/FLINK-5961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel

Kostas Kloudas reassigned FLINK-5961:

    Assignee: Kostas Kloudas

> Queryable State is broken for HeapKeyedStateBackend
> ---------------------------------------------------
>                 Key: FLINK-5961
>                 URL: https://issues.apache.org/jira/browse/FLINK-5961
>             Project: Flink
>          Issue Type: Bug
>          Components: Queryable State
>    Affects Versions: 1.2.0
>            Reporter: Stefan Richter
>            Assignee: Kostas Kloudas
> The current implementation of queryable state on `HeapKeyedStateBackend` attempts to
handle concurrency by using `ConcurrentHashMap`s as datastructure.
> However, the implementation has at least two issues:
> 1) Concurrent modifications of state objects: state can be modified concurrently to a
query, e.g. an element being removed from a list. This can result in exceptions or incorrect
> 2) StateDescriptor is indicating whether a `ConcurrentHashMap` is required because queryable
state is active. On restore, this information is unknown at first and the implementation always
uses plain hash maps. When the state is then finally registered, all previously existing maps
are not thread-safe.

This message was sent by Atlassian JIRA

View raw message