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 kcz <57...@qq.com> on 2020/07/14 13:44:33 UTC

回复：flink-1.11 DDL 设置chk目录问题

谢谢 我一直用的是 streamEnv去设置config 今天看到table也可以，如果我用stream去设置 也是可以的吧





------------------ 原始邮件 ------------------
发件人: Leonard Xu <xbjtdcq@gmail.com&gt;
发送时间: 2020年7月14日 20:34
收件人: user-zh <user-zh@flink.apache.org&gt;
主题: 回复：flink-1.11 DDL 设置chk目录问题



Hi，

没有太理解在DDL中设置，TableConfig上也可以设置 StreamEexecutionEnvironment 的 配置，你要的是这个吗？

tableEnv.getConfig().getConfiguration().set(CHECKPOINTS_DIRECTORY, "your-cp-path");


祝好，
Leonard Xu


&gt; 在 2020年7月14日，18:56，kcz <573693104@qq.com&gt; 写道：
&gt; 
&gt; 目前我只会设置streameEnv.setStateBackend(new FsStateBackend(checkpointPath));
&gt; 但是DDL时候应该如何设置呢？
&gt; tableEnv.getConfig().getConfiguration().set(
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ExecutionCheckpointingOptions.CHECKPOINTING_MODE, CheckpointingMode.EXACTLY_ONCE);
&gt; tableEnv.getConfig().getConfiguration().set(
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ExecutionCheckpointingOptions.CHECKPOINTING_INTERVAL, Duration.ofSeconds(10));