I am new to Flink and trying to understand the keyBy and KeyedStream.  From the 
short doc description I expected it to partition the data such that the 
following flatMap would only see elements with the same key.  That events with 
different keys would be presented to different instances of FlatMapFunction.  
But, I am seeing it present all events in the stream to the same 
FlatMapFunction.

Michael

Reply via email to