Hello everyone, I'm using the CEP library for event stream processing.
I'm splitting the dataStream into different KeyedStreams using keyBy(). In the KeyBy, I'm using a tuple of two elements, which means I may have several millions of KeyedStreams, as I need to monitor all our customer's users. Is this the preferred way to use Flink, or should I find a way to reduce the number of KeyedStreams, for example having one per customer instead of one per customer's user? (And find a way later to process each user by itself). Also, is the bug reported in https://issues.apache.org/jira/browse/FLINK-5174 related to keys of the KeyedStreams? I'm not sure what kind of keys it is related to. If so, is it going to be addressed soon? Thanks, Oriol.
