flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Stephan Ewen (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-1762) Make Statefulness of a Streaming Function explicit
Date Fri, 20 Mar 2015 15:51:39 GMT
Stephan Ewen created FLINK-1762:

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

public interface Statehandle {

 get, put, ...

public interface Stateful {

    void setStateHandle(Statehandle handle);

This message was sent by Atlassian JIRA

View raw message