I've created draft PR for the desired changes [1]. It might be easier to take a look at than the branch.
[1] https://github.com/apache/flink/pull/18237 Cheers, Till On Tue, Dec 28, 2021 at 3:22 PM Till Rohrmann <trohrm...@apache.org> wrote: > Hi everyone, > > I would like to start a discussion about using the working directory to > persist local state for faster recovery (FLIP-201) [1]. Persisting the > local state will be beneficial if a crashed process is restarted with the > same working directory. In this case, Flink does not have to download the > state artifacts again and can recover locally. > > A POC can be found here [2]. > > Looking forward to your feedback. > > [1] https://cwiki.apache.org/confluence/x/wJuqCw > [2] https://github.com/tillrohrmann/flink/tree/FLIP-201 > > Cheers, > Till >
