flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-2664) Remove partitioned states when set to null
Date Mon, 14 Sep 2015 11:33:45 GMT

    [ https://issues.apache.org/jira/browse/FLINK-2664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14743395#comment-14743395

ASF GitHub Bot commented on FLINK-2664:

Github user mbalassi commented on a diff in the pull request:

    --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/state/EagerStateStore.java
    @@ -43,7 +44,7 @@ public EagerStateStore(StateCheckpointer<S, C> checkpointer, StateHandleProvider
    -	public S getStateForKey(Serializable key) throws Exception {
    +	public S getStateForKey(Serializable key) throws IOException {
    --- End diff --
    Why do you specify the exception as IO here?

> Remove partitioned states when set to null
> ------------------------------------------
>                 Key: FLINK-2664
>                 URL: https://issues.apache.org/jira/browse/FLINK-2664
>             Project: Flink
>          Issue Type: Improvement
>          Components: Streaming
>            Reporter: Gyula Fora
>            Assignee: Gyula Fora
> Currently there is no way to remove a specific key from the partitioned state stored
at streaming operators, which can cause unnecessary state accumulation.
> I suggest to remove the partitioned state for the current input when the state is set
to null, and upon next retrieval simply return the default value. This allows the implementation
of streaming programs that can garbage collect their own unwanted state.

This message was sent by Atlassian JIRA

View raw message