xiaodao created FLINK-30412: ------------------------------- Summary: create many checkpoint empty dir when job not enable checkpoint Key: FLINK-30412 URL: https://issues.apache.org/jira/browse/FLINK-30412 Project: Flink Issue Type: Improvement Components: API / DataStream Affects Versions: 1.15.2 Reporter: xiaodao
when we submit job to flink session cluster , after a long time, we find it create too much empty checkpoint dir,and it over hdfs max node limit ; i found StreamingJobGraphGenerator set snapshot whennever the job is open checkpoint; jobGraph.setSnapshotSettings(settings) {code:java} private void configureCheckpointing() CheckpointConfig cfg = streamGraph.getCheckpointConfig(); long interval = cfg.getCheckpointInterval(); if (interval < MINIMAL_CHECKPOINT_TIME) { // interval of max value means disable periodic checkpoint interval = Long.MAX_VALUE; } {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)