Log blob cache and server storage directories at startup
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7c64000d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7c64000d Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/7c64000d Branch: refs/heads/master Commit: 7c64000df1ec982bbe10487c39d76a24e8927aa6 Parents: 9fedfeb Author: Ufuk Celebi <u...@apache.org> Authored: Thu Feb 5 11:48:16 2015 +0100 Committer: Ufuk Celebi <u...@apache.org> Committed: Thu Feb 5 11:56:39 2015 +0100 ---------------------------------------------------------------------- .../main/java/org/apache/flink/runtime/blob/BlobCache.java | 2 ++ .../main/java/org/apache/flink/runtime/blob/BlobServer.java | 7 ++++--- 2 files changed, 6 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/7c64000d/flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobCache.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobCache.java b/flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobCache.java index 41d9a26..0f57ea3 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobCache.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobCache.java @@ -53,6 +53,8 @@ public final class BlobCache implements BlobService { this.serverAddress = serverAddress; this.storageDir = BlobUtils.initStorageDirectory(); + + LOG.info("Created BLOB cache storage directory " + storageDir); } /** http://git-wip-us.apache.org/repos/asf/flink/blob/7c64000d/flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServer.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServer.java b/flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServer.java index 0b02acb..e47a178 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServer.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServer.java @@ -100,7 +100,6 @@ public final class BlobServer extends Thread implements BlobService{ * thrown if the BLOB server cannot bind to a free network port */ public BlobServer() throws IOException { - try { this.serverSocket = new ServerSocket(0); @@ -112,10 +111,12 @@ public final class BlobServer extends Thread implements BlobService{ } this.storageDir = BlobUtils.initStorageDirectory(); - }catch(IOException e){ + + LOG.info("Created BLOB server storage directory " + storageDir); + } + catch (IOException e) { throw new IOException("Could not create BlobServer with random port.", e); } - } /**
