Hi Kevin,
I don't know what your entire program is doing but wouldn't be a
FlatMapFunction containing a state with your biggest value sufficient?
Your stream goes through your FlatMapper and compares with the last
saved biggest value. You can then emit something if the value has increased.
I hope that helps.
Timo
Am 28/07/16 um 17:00 schrieb Kevin Jacobs:
> Hi all,
>
> I am trying to keep track of the biggest value in a stream. I do this
> by using the iterative step mechanism of Apache Flink. However, I get
> an exception that checkpointing is not supported for iterative jobs.
> Why can't this be enabled? My iterative stream is also quite small:
> only one value. Is there a better way to keep track of a largest value
> in a stream?
>
> Regards,
> Kevin
--
Freundliche Grüße / Kind Regards
Timo Walther
Follow me: @twalthr
https://www.linkedin.com/in/twalthr
Locked
