Re: Flink 1.7.1 flink-s3-fs-hadoop-1.7.1 doesn't delete older chk-<id> directories
Posted by
Fabian Hueske-2 on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Flink-1-7-1-flink-s3-fs-hadoop-1-7-1-doesn-t-delete-older-chk-id-directories-tp28148p28152.html
Hi,
I found a few issues in Jira that are related to not deleted checkpoint directories, but only FLINK-10855 [1] seems to be a possible reason in your case.
Is it possible that the checkpoints of the remaining directories failed?
If that's not the case, would you mind creating a Jira issue and describe the bug?
Thank you,
Fabian
Hi,
I am using 1.7.1 and we store checkpoints in Ceph and we use
flink-s3-fs-hadoop-1.7.1 to connect to Ceph. I have only 1 checkpoint
retained. Issue I see is that previous/old chk-<id> directories are still
around. I verified that those older doesn't contain any checkpoint data. But
the directories keep accumulating.
Why is that these old stale directories aren't deleted after part checkpoint
deletion step? Please let me know.
I see :
metacheckpoints/00000000000000000000000000000000/chk-175
metacheckpoints/00000000000000000000000000000000/chk-176
metacheckpoints/00000000000000000000000000000000/chk-177 <- latest
Thanks,
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/