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
Currently we have an Flink pipeline running with Data-Src —> KeyBy —>
ProcessFunction. State Management (with RocksDB) and Timers are working
well.
Now we have to extend this by having another Config Stream which we want to
broadcast to all process operators. So wanted to connect the Data Stream
w
