You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by huayuan <d_...@qq.com> on 2021/03/04 08:48:00 UTC

远程提交flink sql设置了checkpoint，flink sql没有jar包如何恢复呢？

如题
官方的恢复是flink run -s path xxx.jar
那么flink sql没有jar包如何恢复呢

StreamTableEnvironment bsTableEnv = StreamTableEnvironment.create(bsEnv,
bsSettings);
Configuration configuration = bsTableEnv.getConfig().getConfiguration();
configuration.setString("execution.savepoint.path","xxx")貌似不管用



--
Sent from: http://apache-flink.147419.n8.nabble.com/