You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "xiaodao (Jira)" <ji...@apache.org> on 2022/12/14 09:28:00 UTC
[jira] [Created] (FLINK-30412) create many checkpoint empty dir when job not enable checkpoint
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)