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

回复