[jira] (FLINK-27570) A checkpoint path error does not cause the job to stop

[Underwood (Jira)]

Title: Message Title

Underwood deleted a comment on FLINK-27570   Re: A checkpoint path error does not cause the job to stop This time, I ran a task in the IDEA, a wordcount, and filled in a nonexistent path. The phenomenon is different from that before. The result is that the checkpoint is successful, but there is no checkpoint file in this folder.   import org.apache.flink.api.common.restartstrategy.RestartStrategies; import org.apache.flink.api.java.tuple.Tuple2; import org.apache.flink.configuration.ConfigConstants; import org.apache.flink.configuration.Configuration; import org.apache.flink.configuration.RestOptions; import org.apache.flink.runtime.state.storage.FileSystemCheckpointStorage; import org.apache.flink.streaming.api.datastream.DataStream; import org.apache.flink.streaming.api.environment.CheckpointConfig; import org.apache.flink.streaming.api.environment.ExecutionCheckpointingOptions; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; public class StreamWordCount { public static void main(String[] args) throws Exception { Configuration conf = new Configuration(); conf.set (ExecutionCheckpointingOptions.TOLERABLE_FAILURE_NUMBER, 0); conf.setBoolean(ConfigConstants.LOCAL_START_WEBSERVER, true); conf.setInteger(RestOptions.PORT, 8081); StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(conf); env.enableCheckpointing(1000); CheckpointConfig checkpointConfig = env.getCheckpointConfig(); checkpointConfig.setCheckpointStorage( new FileSystemCheckpointStorage("file:///D/Desktop/Log/Flink/noDirectory")); checkpointConfig.setTolerableCheckpointFailureNumber(0); checkpointConfig.setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE); checkpointConfig.setExternalizedCheckpointCleanup( CheckpointConfig.ExternalizedCheckpointCleanup.RETAIN_ON_CANCELLATION);   env.setRestartStrategy(RestartStrategies.noRestart()); env.setParallelism(1); DataStream<String> inputDataStream = env.socketTextStream("localhost", 7777); DataStream<Tuple2<String, Integer>> resultStream = inputDataStream .flatMap(new WordCount.MyFlatMapper()) .setParallelism(1) .keyBy(0) .sum(1) .setParallelism(1) .setParallelism(1); resultStream.print().setParallelism(1); env.execute(); } } Add Comment   This message was sent by Atlassian Jira (v8.20.10#820010-sha1:ace47f9)