flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Gyula Fora (JIRA)" <j...@apache.org>
Subject [jira] [Closed] (FLINK-1762) Make Statefulness of a Streaming Function explicit
Date Wed, 20 May 2015 08:14:59 GMT

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

Gyula Fora closed FLINK-1762.
-----------------------------
    Resolution: Fixed

> Make Statefulness of a Streaming Function explicit
> --------------------------------------------------
>
>                 Key: FLINK-1762
>                 URL: https://issues.apache.org/jira/browse/FLINK-1762
>             Project: Flink
>          Issue Type: Improvement
>          Components: Streaming
>    Affects Versions: 0.9
>            Reporter: Stephan Ewen
>
> Currently, the state of streaming functions stored in the {{StreamingRuntimeContext}}.
> That is rather inexplicit, a function may or may not make use of the state. This also
hides from the system whether a function is stateful or not.
> How about we make this explicit by letting stateful functions extend a special interface
(see below). That would allow the stream graph to already know which functions are stateful.
Certain vertices would not participate in the checkpointing, if they only contain stateless
vertices. We can set up the ExecutionGraph to expect confirmations only from the participating
vertices, saving messages.
> {code}
> public interface Statehandle {
>  get, put, ...
> }
> public interface Stateful {
>     void setStateHandle(Statehandle handle);
> }
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message