[jira] [Created] (FLINK-6615) tmp directory not cleaned up on shutdown

["Andrey (JIRA)" <ji...@apache.org>]

Andrey created FLINK-6615:
-----------------------------

             Summary: tmp directory not cleaned up on shutdown
                 Key: FLINK-6615
                 URL: https://issues.apache.org/jira/browse/FLINK-6615
             Project: Flink
          Issue Type: Bug
    Affects Versions: 1.2.0
            Reporter: Andrey


Steps to reproduce:
1) Stop task manager gracefully (kill -6 )
2) In the logs:
{code}
2017-05-17 13:35:50,147 INFO  org.apache.zookeeper.ClientCnxn                               - EventThread shut down [main-EventThread]
2017-05-17 13:35:50,200 ERROR org.apache.flink.runtime.io.disk.iomanager.IOManager          - IOManager failed to properly clean up temp file directory: /mnt/flink/tmp/flink-io-66f1d0ec-8976-41bf-9575-f80b181b0e47 [flink-akka.actor.default-dispatcher-2]
java.nio.file.DirectoryNotEmptyException: /mnt/flink/tmp/flink-io-66f1d0ec-8976-41bf-9575-f80b181b0e47
	at sun.nio.fs.UnixFileSystemProvider.implDelete(UnixFileSystemProvider.java:242)
	at sun.nio.fs.AbstractFileSystemProvider.delete(AbstractFileSystemProvider.java:103)
	at java.nio.file.Files.delete(Files.java:1126)
	at org.apache.flink.util.FileUtils.deleteDirectory(FileUtils.java:154)
	at org.apache.flink.runtime.io.disk.iomanager.IOManager.shutdown(IOManager.java:109)
	at org.apache.flink.runtime.io.disk.iomanager.IOManagerAsync.shutdown(IOManagerAsync.java:185)
	at org.apache.flink.runtime.taskmanager.TaskManager.postStop(TaskManager.scala:241)
	at akka.actor.Actor$class.aroundPostStop(Actor.scala:477)
{code}

Expected:
* on shutdown delete non-empty directory anyway. 

Notes:
* after process terminated, I've checked "/mnt/flink/tmp/flink-io-66f1d0ec-8976-41bf-9575-f80b181b0e47" directory and didn't find anything there. So it looks like timing issue.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)