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

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

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

huayuan
如题
官方的恢复是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/