Hi Anuj,
connecting a keyed stream and a broadcasted stream is not supported at the
moment but there is work in progress [1] to add this functionality for the
next release (Flink 1.5.0).
Best,
Fabian
[1] https://issues.apache.org/jira/browse/FLINK-3659
2018-01-10 12:21 GMT+01:00 Piotr Nowojski
Hi,
Could you elaborate what is the problem that you are having? What is the
exception(s) that you are getting? I have tested such simple example and it’s
seems to be working as expected:
DataStreamSource input = env.fromElements(1, 2, 3, 4, 5, 1, 2, 3);
DataStreamSource confStream = env.fromE
