Aljoscha Krettek created FLINK-4859: ---------------------------------------
Summary: Clearly Separate Responsibilities of StreamOperator and StreamTask Key: FLINK-4859 URL: https://issues.apache.org/jira/browse/FLINK-4859 Project: Flink Issue Type: Improvement Components: Streaming Reporter: Aljoscha Krettek Priority: Blocker Currently, {{StreamTask}} and {{StreamOperator}} perform a complicated dance for certain operations. For example, when restoring from a snapshot, the state backends are restored in the {{StreamTask}}, but only after {{StreamTask}} calls restore on the operator and the operator asks for the backends. There is no clear separation/modularisation with properly defined interfaces right now. The code works right now but maintainability/understandability could be greatly improved. -- This message was sent by Atlassian JIRA (v6.3.4#6332)