??????????????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