[
https://issues.apache.org/jira/browse/FLINK-30412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652768#comment-17652768
]
Yun Gao commented on FLINK-30412:
---------------------------------
Hi [~xiaodao] sorry for the late reply, may I have a double check on the
version you are using? Since From the stack, it seems it is still trying to
create a JobManagerRunner object, but JobManagerRunner has been changed to be
an interface since 1.10: https://issues.apache.org/jira/browse/FLINK-14259
Since https://issues.apache.org/jira/browse/FLINK-23180 is merged in 1.15, if
you are using a version earlier than 1.15.0 I reckon it might be fixed by
upgrading.
> 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)
