[
https://issues.apache.org/jira/browse/BEAM-5396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16618418#comment-16618418
]
Thomas Weise commented on BEAM-5396:
------------------------------------
The operability features are table stakes for serious projects. They include
not only a story for compatibility and upgrades, but also metrics, logging etc.
I think that we should track these in the 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)
