flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Adam Atrea <atreaa...@gmail.com>
Subject streaming restored state after restart
Date Thu, 11 Jun 2020 12:58:09 GMT

I'm new to Flink - but after reading the documentation -

What would be the best approach to stream data from a restored state
following a job restart ?
Say I have a MapState that gets populated during streaming with various
computed results within a stateful operator.

Upon job restart or on task failure recovery I am looking to stream the
data from that restored state downstream so that the operator will replay
The data just to be directed to the downstream - at least once - so
multiple tasks may submit the same data.



View raw message