Cloudera Docs

Resuming Flink applications

After updating the Cloudera Streaming Analytics artifacts, you can resume your application by the Flink run command. In case you have stopped your application by creating a savepoint, you must add the savepoint location to the command.

Resuming Flink applications without state

  1. Connect to your host where you run your Flink jobs using ssh.
    ssh root@[***FLINK HOSTNAME***]
Password:[***PASSWORD***]
  2. Submit your Flink application that was stopped before the upgrade.
    flink run [***RUN ARGUMENTS***] \
[***JAR FILE***] [***APP ARGUMENTS***]

Resuming stateful Flink applications

  1. Connect to your host where you run your Flink jobs using ssh.
    ssh root@[***FLINK HOSTNAME***]
Password:[***PASSWORD***]
  2. Submit your Flink application that was stopped before the upgrade.
    flink run [***RUN ARGUMENTS***] \
-fromSavepoint hdfs:///tmp/savepoints/[***SAVEPOINT NAME***] \ 
[***JAR FILE***] [***APP ARGUMENTS***]