[jira] [Created] (FLINK-1409) Connected datastream functionality broken since the introduction of intermediate results

[Shang Yuanchun (Jira)]

Gyula Fora created FLINK-1409:
---------------------------------

             Summary: Connected datastream functionality broken since the introduction of intermediate results
                 Key: FLINK-1409
                 URL: https://issues.apache.org/jira/browse/FLINK-1409
             Project: Flink
          Issue Type: Bug
          Components: Streaming
    Affects Versions: 0.9
            Reporter: Gyula Fora
            Assignee: Gyula Fora


The connected data stream functionality which allows joint transformations on two data streams of arbitrary type is broken since Ufuk's commit which introduces the intermediate results.

The problem is most likely in the CoRecordReader which should allow nonblocking read from inputs with different types.



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