[FLINK-21471] jobmanger, taskmanager, and job hang abnormally, and the blobstore directory is not deleted

• Type: Bug
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Affects Version/s: 1.11.0
• Fix Version/s: 1.11.0, 1.12.0
• Component/s: Runtime / Coordination
• Labels: auto-deprioritized-major
• Assignee: Unassigned
• Reporter: kangTwang
• Created: 24/Feb/21 01:59
• Updated: 29/Apr/21 22:57

Description

There are currently two issues as follows:
1. When flink hangs abnormally, the directory corresponding to blobstore is not deleted, causing the disk to burst and failing to submit the flink application
2. When the flink job application crashes abnormally, the job_id corresponding directory in the blobstore directory is not deleted, which causes the directory to increase continuously, causing the disk to burst
Check the flink source code, the directory will be deleted only when flink is shut down normally, it will not be deleted if it is shut down abnormally. The current solution is to find the running blobstore directory by checking the flink log and manually delete the useless blobstore , Is there a good solution? ? ?