[ https://issues.apache.org/jira/browse/BEAM-5396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16618442#comment-16618442 ]
Ankur Goenka commented on BEAM-5396: ------------------------------------ Makes sense. Its a runner specific functionality so its a good idea to track it in feature matrix. > Flink portable runner savepoint / upgrade support > ------------------------------------------------- > > Key: BEAM-5396 > URL: https://issues.apache.org/jira/browse/BEAM-5396 > Project: Beam > Issue Type: Improvement > Components: runner-flink > Reporter: Thomas Weise > Priority: Major > > The Flink runner overall and the new portable implementation specifically > need to support Flink savepoints for production use. Specifically, it should > be possible to upgrade a stateful portable Beam pipeline that runs on Flink, > which involves taking a savepoint and then starting the new version of the > pipeline from that savepoint. The potential issues with pipeline evolution > and migration are similar to those when using the Flink DataStream API > (schema / name changes etc.). -- This message was sent by Atlassian JIRA (v7.6.3#76005)