flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Igal Shilman <i...@ververica.com>
Subject Re: “feedback loop” and checkpoints in itearative streams
Date Mon, 06 Apr 2020 09:55:18 GMT
I don't know what is the status of iterations at the moment, and whatever
the community has plans to work at that,
But I would like to point you to Flink Stateful Functions [1], a recent
contribution to Apache Flink that allows building
applications composed of stateful functions that can invoke (message) each
other in an arbitrary order (not necessarily a DAG)

Kind regards,

[1] https://github.com/apache/flink-statefun

On Sat, Apr 4, 2020 at 12:54 PM Sharipov, Rinat <r.sharipov@cleverdata.ru>

> Hi mates, for some reason, it's necessary to create a feedback look in my
> streaming application.
> The best choice to implement it was iterative stream, but at the moment of
> job implementation (flink version is 1.6.1) it wasn't checkpointed.
> So I decided to write this output into kafka.
> As I see, there is no changes at this moment (from official docs)
> > Please note that records in flight in the loop edges (and the state
> changes associated with them) will be lost during failure.
> Does the community have any plans to fix this behaviour ?
> thx !

View raw message