flink-1.11 DDL 设置chk目录问题

[kcz]

目前我只会设置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));

[Leonard Xu]

Hi，

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

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


祝好，
Leonard Xu


> 在 2020年7月14日，18:56，kcz <[hidden email]> 写道：
>
> 目前我只会设置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));

[kcz]

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





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