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)
