flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Gyula Fora (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-2054) StreamOperator rework removed copy calls when passing output to a chained operator
Date Wed, 20 May 2015 08:34:59 GMT
Gyula Fora created FLINK-2054:
---------------------------------

             Summary: 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
            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)

Mime
View raw message