You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Piyush Shrivastava <pi...@yahoo.co.in> on 2016/05/09 10:17:22 UTC
Sorted output
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
Re: Sorted output
Posted by Piyush Shrivastava <pi...@yahoo.co.in>.
This is now solved, thank you. :-)
Thanks and Regards,Piyush Shrivastava
http://webograffiti.com
On Monday, 9 May 2016 3:47 PM, Piyush Shrivastava <pi...@yahoo.co.in> 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