Hello all, I have a time series based logic written with Flink. Due to the parallelism, I am not getting the output in a proper series.For example, 3> (12:00:00, "value") appears before 1> (11:59:00, "value") while the timestamp of the latter is smaller than the former. I am using TimeWindow and apply (WindowFunction) functionalities. How can I sort the output? Thanks and Regards,Piyush Shrivastava http://webograffiti.com
- Sorted output Piyush Shrivastava
- Re: Sorted output Piyush Shrivastava