flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Gyula Fora (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-2664) Remove partitioned states when set to null
Date Mon, 14 Sep 2015 09:26:45 GMT
Gyula Fora created FLINK-2664:

             Summary: 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