Repository: flink Updated Branches: refs/heads/master 58e1e4437 -> ce8acc492
[FLINK-1372] Re-add logging of temp directories at task manager startup Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8d73d45a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8d73d45a Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/8d73d45a Branch: refs/heads/master Commit: 8d73d45a7f087f36baa60a23605c7d84825aa303 Parents: d2dd78f Author: Ufuk Celebi <[email protected]> Authored: Tue Jan 20 20:04:21 2015 +0100 Committer: Ufuk Celebi <[email protected]> Committed: Tue Jan 20 20:29:03 2015 +0100 ---------------------------------------------------------------------- .../apache/flink/runtime/taskmanager/TaskManager.scala | 11 +++++++++++ 1 file changed, 11 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/8d73d45a/flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala b/flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala index 62081a3..d808e8e 100644 --- a/flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala +++ b/flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala @@ -773,6 +773,17 @@ object TaskManager { if (!file.canWrite) { throw new Exception(s"Temporary file directory ${file.getAbsolutePath} is not writable.") } + + if (LOG.isInfoEnabled()) { + val totalSpaceGb = file.getTotalSpace() >> 30; + val usableSpaceGb = file.getUsableSpace() >> 30; + val usablePercentage = usableSpaceGb.asInstanceOf[Double] / totalSpaceGb * 100; + + val path = file.getAbsolutePath() + + LOG.info(f"Temporary file directory '$path': total $totalSpaceGb GB," + + f"usable $usableSpaceGb GB [$usablePercentage%.2f%% usable])") + } case (_, id) => throw new Exception(s"Temporary file directory #${id} is null.") }
