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)
