Thomas Weise created BEAM-5396:
----------------------------------
Summary: 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
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)
