You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/10/09 04:57:00 UTC
[jira] [Assigned] (FLINK-6615) tmp directory not cleaned up on
shutdown
[ https://issues.apache.org/jira/browse/FLINK-6615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Bowen Li reassigned FLINK-6615:
-------------------------------
Assignee: Bowen Li
> tmp directory not cleaned up on shutdown
> ----------------------------------------
>
> Key: FLINK-6615
> URL: https://issues.apache.org/jira/browse/FLINK-6615
> Project: Flink
> Issue Type: Bug
> Components: Local Runtime
> Affects Versions: 1.2.0
> Reporter: Andrey
> Assignee: Bowen Li
>
> 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.4.14#64029)