[
https://issues.apache.org/jira/browse/BEAM-5396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16618330#comment-16618330
]
Ankur Goenka commented on BEAM-5396:
------------------------------------
Thanks for the reference link. Its very relevant.
This feature require quite a bit of effort. We can start thing of a design
while we are improving portability and once we are stable, we can get to this
feature.
> 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)
