谢谢 我一直用的是 streamEnv去设置config 今天看到table也可以,如果我用stream去设置 也是可以的吧
------------------ 原始邮件 ------------------ 发件人: Leonard Xu <xbjt...@gmail.com> 发送时间: 2020年7月14日 20:34 收件人: user-zh <user-zh@flink.apache.org> 主题: 回复:flink-1.11 DDL 设置chk目录问题 Hi, 没有太理解在DDL中设置,TableConfig上也可以设置 StreamEexecutionEnvironment 的 配置,你要的是这个吗? tableEnv.getConfig().getConfiguration().set(CHECKPOINTS_DIRECTORY, "your-cp-path"); 祝好, Leonard Xu > 在 2020年7月14日,18:56,kcz <573693...@qq.com> 写道: > > 目前我只会设置streameEnv.setStateBackend(new FsStateBackend(checkpointPath)); > 但是DDL时候应该如何设置呢? > tableEnv.getConfig().getConfiguration().set( > ExecutionCheckpointingOptions.CHECKPOINTING_MODE, CheckpointingMode.EXACTLY_ONCE); > tableEnv.getConfig().getConfiguration().set( > ExecutionCheckpointingOptions.CHECKPOINTING_INTERVAL, Duration.ofSeconds(10));