[jira] [Closed] (FLINK-2054) StreamOperator rework removed copy calls when passing output to a chained operator

["Aljoscha Krettek (JIRA)" <ji...@apache.org>]

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

Aljoscha Krettek closed FLINK-2054.
-----------------------------------
       Resolution: Fixed
    Fix Version/s: 0.9

Resolved in https://github.com/apache/flink/commit/26304c20ab6aab33daba775736061102bd7a2409

> StreamOperator rework removed copy calls when passing output to a chained operator
> ----------------------------------------------------------------------------------
>
>                 Key: FLINK-2054
>                 URL: https://issues.apache.org/jira/browse/FLINK-2054
>             Project: Flink
>          Issue Type: Bug
>          Components: Streaming
>            Reporter: Gyula Fora
>            Assignee: Aljoscha Krettek
>            Priority: Blocker
>             Fix For: 0.9
>
>
> Before the recent rework of stream operators to be push based, operators held the semantics that any input (and also output to be specific) will not be mutated afterwards. This was achieved by simply copying records that were passed to other chained operators.
> This feature has been removed thus introducing a major break in the operator mutability guarantees. 
> To make chaining viable in all cases (and to prevent hidden bugs) we need to reintroduce the copying logic. 



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