[
https://issues.apache.org/jira/browse/FLINK-30412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaodao updated FLINK-30412:
----------------------------
Attachment: image-2022-12-23-09-24-58-584.png
> 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.12.7, 1.13.6, 1.15.2
> Reporter: xiaodao
> Priority: Major
> Attachments: image-2022-12-23-09-24-58-584.png
>
>
> 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)
