Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-5396

Flink portable runner savepoint / upgrade support

    XMLWordPrintableJSON

    Details

      Description

      The portable Flink runner needs to support Flink savepoints for production use. 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.).

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                mxm Maximilian Michels
                Reporter:
                thw Thomas Weise
              • Votes:
                0 Vote for this issue
                Watchers:
                4 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved:

                  Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 12h 20m
                  12h 20m