>From my understanding, having a fake keyBy (stream.keyBy(r => "dummyString")) means there would be only one slot handling the data. Would a broadcast function [1] work for your case?
Regards, Averell [1] https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/state/broadcast_state.html -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
