[
https://issues.apache.org/jira/browse/FLINK-2054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14564645#comment-14564645
]
Gyula Fora commented on FLINK-2054:
-----------------------------------
[~aljoscha] have you started working on this?
I think we need to have this for the release.
> 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
>
> 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)
