Flink 1.5.2 process keeps reference to deleted blob files.

2018-09-19 Thread Piotr Szczepanek
Hello, we are using YarnClusterClient for job submission. After successful/failed job execution it looks like blob file for that job is deleted, but there is still some handle from Flink process to that file. As a result the file is not removed from machine and we faced no space felt on device err

Re: Flink 1.5.2 process keeps reference to deleted blob files.

2018-09-20 Thread Stefan Richter
Hi, I think it would be very helpful if you could identify what data is behind. For example, I could imagine that it can be a jar file that was used by the TM and some classes are still in use or loaded by a classloader that was not yet GCed. Depending on that, there could be a problem in the u