Re: flink-1.11 DDL 设置chk目录问题

[Leonard Xu]

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));