??????????????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));
- flink-1.11 DDL ????chk???????? kcz
- Re: flink-1.11 DDL 设置chk目录问题 Leonard Xu
