On Wed, Dec 30, 2020 at 10:47 AM Till Rohrmann <trohrm...@apache.org> wrote:
Till, > sorry for overlooking your colleague's email. Not a problem at all! Thanks for the response to my email. > A bit confusing is that FLINK-16998 explicitly > states that this change is not breaking backwards compatibility. The comments regarding backwards compatibility are the reason why I assumed that this behavior might be unintended. If it's not a bug we're probably going to try rebuilding the state of the affected jobs. Just wanted to reach out in case this is not the intended behavior. > What you could try to use as a workaround is Flink's state processor API > [2] which allows you to rewrite savepoints. I briefly looked into the state processor API, but I wasn't sure if the version in 1.11 would work for us as it seems that support for reading window state was only added in 1.12 (upgrading to 1.12 would require larger changes as we're still using some deprecated APIs that have been removed in 1.12). - Guenther
