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