Upgrading Flink
This section describes how to upgrade Flink.
- If you want to save any running job and use it in future, stop the job
and create a
savepoint:
/opt/mapr/flink/flink-<version>/bin/flink stop <job_id> --savepointPath <savepoints_directory>Save the given in the output savepoint path (you may want to use after reinstallation).
- To stop any running Flink cluster (YARN application), run the following
command:
echo "stop" | /opt/mapr/flink/flink-<version>/bin/yarn-session.sh -id <application_id> -
Run the applicable commands as the cluster admin (typically the
mapruser), to upgrade through CLI:- Ubuntu
apt upgrade mapr-flink- RHEL
yum update mapr-flink
- Start the Flink
cluster:
/opt/mapr/flink/flink-<version>/bin/yarn-session.sh --detached - Resume your job from the savepoint that was saved in Step
1:
/opt/mapr/flink/flink-<version>/bin/flink run -s <given_savepoint_path> -d t <job_jar>