This is now solved, thank you. :-)
Thanks and Regards,Piyush Shrivastava
http://webograffiti.com
On Monday, 9 May 2016 3:47 PM, Piyush Shrivastava <[email protected]>
wrote:
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
