OSDir


[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
(v.1.4)?

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
jobmanager.

Note that automatic restarting from checkpoints and creating savepoints is
working.

Thank you for your help.





--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/