[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Starting beam pipeline from savepoint

Is it possible to start Beam pipelines from savepoints when running on Flink

I am running flink in a remote environment, and executing the pipelines as
.jars specifying the flink jobmanager via cmd line arguments. This is
opposed to passing the .jar to `flink run`.

In this way the jar files are not directly available to the jobmanager, and
indeed the API /jars returns empty. 

Now to restart from a savepoint (either using the REST API or CLI) it is
expected that I pass the pipeline jar. However this is not available to the

Note that automatic restarting from checkpoints and creating savepoints is

Thank you for your help.

Sent from:

( ! ) Warning: include(msgfooter.php): failed to open stream: No such file or directory in /var/www/git/apache-flink-users/msg09411.html on line 94
Call Stack
10.0009362904{main}( ).../msg09411.html:0

( ! ) Warning: include(): Failed opening 'msgfooter.php' for inclusion (include_path='.:/var/www/git') in /var/www/git/apache-flink-users/msg09411.html on line 94
Call Stack
10.0009362904{main}( ).../msg09411.html:0