Hi Artur, Is that possible to make that "static" stream a keyedStream basing on that foreign key? If yes, then just connect the two streams, keyed on that foreign key. In the CoProcessFunction, for every single record from the static stream, you write its content into a ValueState; and for every record from the main stream, you read the enrichment data from the saved ValueState to enrich that mainstream record.
If no, then I am having the same issue :D Looking at Broadcast State, but there is still something that doesn't look right for me. Regards, Averell -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
