Re: Automatically Clearing Temporary Directories

2020-03-16 Thread David Maddison
Thanks for the responses and thanks Gary for the confirmation. Just to give some background, we deploy Flink inside Kubernetes so there is a chance that TaskManagers COULD be shut down in a non-graceful way leaving cache artifacts on the temporary volumes. With Gary's confirmation, we'll add an

Re: Automatically Clearing Temporary Directories

2020-03-12 Thread Gary Yao
Hi David, > Would it be safe to automatically clear the temporary storage every time when a TaskManager is started? > (Note: the temporary volumes in use are dedicated to the TaskManager and not shared :-) Yes, it is safe in your case. Best, Gary On Tue, Mar 10, 2020 at 6:39 PM David Maddison

Re: Automatically Clearing Temporary Directories

2020-03-10 Thread Yang Wang
Hi David, Currently, the TaskManager could cleanup the non-referenced files in blob cache. It could configured via `blob.service.cleanup.interval`[1]. Also when the TaskManager is shut down gracefully, the storage directory will be deleted. So do you stop your TaskManager forcibly(i.e. kill -9)?

Automatically Clearing Temporary Directories

2020-03-10 Thread David Maddison
Hi, When a TaskManager is restarted it can leave behind unreferenced BlobServer cache directories in the temporary storage that never get cleaned up. Would it be safe to automatically clear the temporary storage every time when a TaskManager is started? (Note: the temporary volumes in use are