Does any know if this is a correct assumption

DataStream<KeyedAvroRecord> sorted = stream.keyBy("partition");

Will automattically put same record to the same sink thread ?

The behavior I am seeing is that a Sink setup with multiple threads is see data 
from the same hour.
Any good examples of how to sort data so that Sink threads only get the same 
type of data ?

Reply via email to