当使用Flink远程环境时,如何通过savepoint运行作业?我找不到任何api可供应用。
发布于 2018-08-06 16:02:02
您可以使用ClusterClient#run(JobWithJars, int, SavepointRestoreSettings)。
发布于 2018-08-07 02:32:51
我认为你可以使用这个命令:
$ bin/flink run -s :savepointPath [:runArgs]
有关详细信息,请参阅docs。
https://stackoverflow.com/questions/51683797
相似问题