flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From u..@apache.org
Subject [2/3] flink git commit: Log blob cache and server storage directories at startup
Date Thu, 05 Feb 2015 10:56:53 GMT
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 <uce@apache.org>
Authored: Thu Feb 5 11:48:16 2015 +0100
Committer: Ufuk Celebi <uce@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);
 		}
-
 	}
 
 	/**


Mime
View raw message