[
https://issues.apache.org/jira/browse/FLINK-2054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14576998#comment-14576998
]
ASF GitHub Bot commented on FLINK-2054:
---------------------------------------
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/803#issuecomment-109944731
Ok, I'm working on it.
> 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)
