请教个Flink savepoint的问题

Mon, 11 Jan 2021 03:07:46 -0800 

Flink APi 中我们在java代码中使用客户端调用类ClusterClient如下的方法停止了任务：
CompletableFuture<String> stopWithSavepoint(JobID var1, boolean var2, @Nullable 
String var3);然后我们保存了该任务的savepoint信息，那恢复时没看到对应的恢复方法，找了些资料都是通过命令来恢复，有没有直接调用Java 
API 层次的方法来恢复任务？



[email protected]

回复