Sorted output

[Piyush Shrivastava]

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?

 

[Piyush Shrivastava]

This is now solved, thank you. :-)

 

On Monday, 9 May 2016 3:47 PM, Piyush Shrivastava <[hidden email]> 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?