[
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)
