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

Tue, 14 Jul 2020 06:46:11 -0700 

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





------------------ 原始邮件 ------------------
发件人: Leonard Xu <[email protected]&gt;
发送时间: 2020年7月14日 20:34
收件人: user-zh <[email protected]&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 <[email protected]&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));

回复